diff options
| author | Gordon Sim <gsim@apache.org> | 2008-04-24 21:07:34 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2008-04-24 21:07:34 +0000 |
| commit | 1c86294add5cbb640aac7f458c4de693de48dd9f (patch) | |
| tree | 22d7774e00c7514c4b76be5cf8b50727b74fe4e3 /cpp/src/qpid/broker/SessionHandler.h | |
| parent | 96f12949244b5af2b717156823309b66fe7bfb84 (diff) | |
| download | qpid-python-1c86294add5cbb640aac7f458c4de693de48dd9f.tar.gz | |
Generate c++ code from final 0-10 spec
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@651423 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/SessionHandler.h')
| -rw-r--r-- | cpp/src/qpid/broker/SessionHandler.h | 12 |
1 files changed, 4 insertions, 8 deletions
diff --git a/cpp/src/qpid/broker/SessionHandler.h b/cpp/src/qpid/broker/SessionHandler.h index c299c465cf..47c534441a 100644 --- a/cpp/src/qpid/broker/SessionHandler.h +++ b/cpp/src/qpid/broker/SessionHandler.h @@ -46,7 +46,7 @@ class SessionState; * receives incoming frames, handles session controls and manages the * association between the channel and a session. */ -class SessionHandler : public framing::AMQP_ServerOperations::Session010Handler, +class SessionHandler : public framing::AMQP_ServerOperations::SessionHandler, public framing::FrameHandler::InOutHandler, private boost::noncopyable { @@ -66,9 +66,8 @@ class SessionHandler : public framing::AMQP_ServerOperations::Session010Handler, framing::AMQP_ClientProxy& getProxy() { return proxy; } const framing::AMQP_ClientProxy& getProxy() const { return proxy; } - // Called by closing connection. - void localSuspend(); - void detach() { localSuspend(); } + void requestDetach(); + void handleDetach(); void sendCompletion(); protected: @@ -93,9 +92,6 @@ class SessionHandler : public framing::AMQP_ServerOperations::Session010Handler, void flush(bool expected, bool confirmed, bool completed); void gap(const framing::SequenceSet& commands); - //hacks for old generator: - void commandPoint(uint32_t id, uint64_t offset) { commandPoint(framing::SequenceNumber(id), offset); } - void assertAttached(const char* method) const; void assertActive(const char* method) const; void assertClosed(const char* method) const; @@ -105,7 +101,7 @@ class SessionHandler : public framing::AMQP_ServerOperations::Session010Handler, Connection& connection; framing::ChannelHandler channel; framing::AMQP_ClientProxy proxy; - framing::AMQP_ClientProxy::Session010 peerSession; + framing::AMQP_ClientProxy::Session peerSession; bool ignoring; std::auto_ptr<SessionState> session; std::string name;//TODO: this should be part of the session state and replace the id |