diff options
| author | Alan Conway <aconway@apache.org> | 2008-01-29 14:48:59 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2008-01-29 14:48:59 +0000 |
| commit | 6b6dfc1709eace6db0c624676ad297e34fef4aa7 (patch) | |
| tree | fb397c690916219439994edb19072ab5f6254a27 /cpp/src/qpid/broker | |
| parent | ff63c19a83d95fa8f0116424d609e61df9085500 (diff) | |
| download | qpid-python-6b6dfc1709eace6db0c624676ad297e34fef4aa7.tar.gz | |
Deleted unused classes, adjusted files that still mention them.
D src/qpid/framing/ChannelAdapter.cpp
D src/qpid/framing/ChannelAdapter.h
D src/qpid/framing/HandlerUpdater.h
D src/tests/BrokerChannelTest.cpp
D src/tests/MockChannel.h
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@616353 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker')
| -rw-r--r-- | cpp/src/qpid/broker/Broker.cpp | 13 | ||||
| -rw-r--r-- | cpp/src/qpid/broker/Broker.h | 13 |
2 files changed, 0 insertions, 26 deletions
diff --git a/cpp/src/qpid/broker/Broker.cpp b/cpp/src/qpid/broker/Broker.cpp index 8edbb25cd5..06a0d33a85 100644 --- a/cpp/src/qpid/broker/Broker.cpp +++ b/cpp/src/qpid/broker/Broker.cpp @@ -35,7 +35,6 @@ #include "qpid/log/Statement.h" #include "qpid/Url.h" #include "qpid/framing/AMQFrame.h" -#include "qpid/framing/HandlerUpdater.h" #include "qpid/framing/ProtocolInitiation.h" #include "qpid/sys/Acceptor.h" #include "qpid/sys/ConnectionInputHandler.h" @@ -49,7 +48,6 @@ #include <memory> using qpid::sys::Acceptor; -using qpid::framing::HandlerUpdater; using qpid::framing::FrameHandler; using qpid::framing::ChannelId; using qpid::management::ManagementAgent; @@ -238,17 +236,6 @@ Acceptor& Broker::getAcceptor() const { return *acceptor; } -void Broker::add(const shared_ptr<HandlerUpdater>& updater) { - QPID_LOG(debug, "Broker added HandlerUpdater"); - handlerUpdaters.push_back(updater); -} - -void Broker::update(ChannelId channel, FrameHandler::Chains& chains) { - for_each(handlerUpdaters.begin(), handlerUpdaters.end(), - boost::bind(&HandlerUpdater::update, _1, - channel, boost::ref(chains))); -} - ManagementObject::shared_ptr Broker::GetManagementObject(void) const { return dynamic_pointer_cast<ManagementObject> (mgmtObject); diff --git a/cpp/src/qpid/broker/Broker.h b/cpp/src/qpid/broker/Broker.h index 32a3ea55f7..1917da83cc 100644 --- a/cpp/src/qpid/broker/Broker.h +++ b/cpp/src/qpid/broker/Broker.h @@ -46,11 +46,6 @@ #include <vector> namespace qpid { - -namespace framing { -class HandlerUpdater; -} - namespace broker { /** @@ -99,12 +94,6 @@ class Broker : public sys::Runnable, public Plugin::Target, public management::M /** Shut down the broker */ virtual void shutdown(); - /** Register a handler updater. */ - void add(const shared_ptr<framing::HandlerUpdater>&); - - /** Apply all handler updaters to a handler chain pair. */ - void update(framing::ChannelId, framing::FrameHandler::Chains&); - void setStore (MessageStore*); MessageStore& getStore() { return *store; } QueueRegistry& getQueues() { return queues; } @@ -125,13 +114,11 @@ class Broker : public sys::Runnable, public Plugin::Target, public management::M Options config; sys::Acceptor::shared_ptr acceptor; MessageStore* store; - typedef std::vector<shared_ptr<framing::HandlerUpdater> > HandlerUpdaters; QueueRegistry queues; ExchangeRegistry exchanges; ConnectionFactory factory; DtxManager dtxManager; - HandlerUpdaters handlerUpdaters; SessionManager sessionManager; management::ManagementAgent::shared_ptr managementAgent; management::Broker::shared_ptr mgmtObject; |
