diff options
| author | Gordon Sim <gsim@apache.org> | 2008-02-21 17:40:42 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2008-02-21 17:40:42 +0000 |
| commit | 3767d7e49e80c268c60ee247b3526b986eb7fc17 (patch) | |
| tree | 36f0c9487e54705530be26271de7e52676bad524 /cpp/src/qpid/broker/Connection.h | |
| parent | 5f06a953368f7f41dd8ab94a6775fcd9b5c99792 (diff) | |
| download | qpid-python-3767d7e49e80c268c60ee247b3526b986eb7fc17.tar.gz | |
Start moving towards final 0-10 spec:
* marked preview spec as 99-0 to distinguish it from 0-10 (which will now be used for the final version)
* modified python client to treat 99-0 as 0-10 for now
* modified broker to have two paths for the two different versions: 99-0 uses PreviewConnection, PreviewConnectionHandler
and PreviewSessionHandler which are straight copy & pastes of the Connection, ConnectionHandler and SessionHandler now
associated with 0-10 (so we can migrate the 0-10 path to the final spec without affecting clients working with the preview
version)
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@629883 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/Connection.h')
| -rw-r--r-- | cpp/src/qpid/broker/Connection.h | 32 |
1 files changed, 2 insertions, 30 deletions
diff --git a/cpp/src/qpid/broker/Connection.h b/cpp/src/qpid/broker/Connection.h index 99b394dda0..8719a9dfcd 100644 --- a/cpp/src/qpid/broker/Connection.h +++ b/cpp/src/qpid/broker/Connection.h @@ -39,6 +39,7 @@ #include "qpid/sys/Socket.h" #include "qpid/Exception.h" #include "ConnectionHandler.h" +#include "ConnectionState.h" #include "SessionHandler.h" #include "qpid/management/Manageable.h" #include "qpid/management/Client.h" @@ -50,8 +51,7 @@ namespace qpid { namespace broker { class Connection : public sys::ConnectionInputHandler, - public ConnectionToken, - public management::Manageable + public ConnectionState { public: Connection(sys::ConnectionOutputHandler* out, Broker& broker, const std::string& mgmtId); @@ -63,25 +63,6 @@ class Connection : public sys::ConnectionInputHandler, /** Close the connection */ void close(framing::ReplyCode code, const string& text, framing::ClassId classId, framing::MethodId methodId); - sys::ConnectionOutputHandler& getOutput() const { return *out; } - framing::ProtocolVersion getVersion() const { return version; } - - uint32_t getFrameMax() const { return framemax; } - uint16_t getHeartbeat() const { return heartbeat; } - uint64_t getStagingThreshold() const { return stagingThreshold; } - - void setFrameMax(uint32_t fm) { framemax = fm; } - void setHeartbeat(uint16_t hb) { heartbeat = hb; } - void setStagingThreshold(uint64_t st) { stagingThreshold = st; } - - Broker& getBroker() { return broker; } - - Broker& broker; - std::vector<Queue::shared_ptr> exclusiveQueues; - - //contained output tasks - sys::AggregateOutput outputTasks; - // ConnectionInputHandler methods void received(framing::AMQFrame& frame); void initiated(const framing::ProtocolInitiation& header); @@ -98,9 +79,6 @@ class Connection : public sys::ConnectionInputHandler, management::Manageable::status_t ManagementMethod (uint32_t methodId, management::Args& args); - void setUserId(const string& uid); - const string& getUserId() const; - void initMgmt(bool asLink = false); private: @@ -126,17 +104,11 @@ class Connection : public sys::ConnectionInputHandler, class MgmtClient; class MgmtLink; - framing::ProtocolVersion version; ChannelMap channels; - sys::ConnectionOutputHandler* out; - uint32_t framemax; - uint16_t heartbeat; framing::AMQP_ClientProxy::Connection* client; - uint64_t stagingThreshold; ConnectionHandler adapter; std::auto_ptr<MgmtWrapper> mgmtWrapper; bool mgmtClosing; - string userId; const std::string mgmtId; }; |
