From 1c86294add5cbb640aac7f458c4de693de48dd9f Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Thu, 24 Apr 2008 21:07:34 +0000 Subject: 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 --- cpp/src/qpid/broker/SessionHandler.h | 12 ++++-------- 1 file changed, 4 insertions(+), 8 deletions(-) (limited to 'cpp/src/qpid/broker/SessionHandler.h') 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 session; std::string name;//TODO: this should be part of the session state and replace the id -- cgit v1.2.1