summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/SessionHandler.h
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2008-02-01 18:21:01 +0000
committerGordon Sim <gsim@apache.org>2008-02-01 18:21:01 +0000
commit5891c19a838bd8987fbc04d23923f4f5f2ca4636 (patch)
tree1b8b75e076ebded9b57c84b547b8cf9b80a71427 /cpp/src/qpid/broker/SessionHandler.h
parent4db96f7ad47c69982cdc6cf7b5e5c47b00f1144b (diff)
downloadqpid-python-5891c19a838bd8987fbc04d23923f4f5f2ca4636.tar.gz
Initial cut of inter-broker bridging
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@617590 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/SessionHandler.h')
-rw-r--r--cpp/src/qpid/broker/SessionHandler.h7
1 files changed, 7 insertions, 0 deletions
diff --git a/cpp/src/qpid/broker/SessionHandler.h b/cpp/src/qpid/broker/SessionHandler.h
index 9a68ddb46f..6f6f5e941f 100644
--- a/cpp/src/qpid/broker/SessionHandler.h
+++ b/cpp/src/qpid/broker/SessionHandler.h
@@ -23,6 +23,7 @@
*/
#include "qpid/framing/FrameHandler.h"
+#include "qpid/framing/AMQP_ClientOperations.h"
#include "qpid/framing/AMQP_ServerOperations.h"
#include "qpid/framing/AMQP_ClientProxy.h"
#include "qpid/framing/amqp_types.h"
@@ -43,6 +44,7 @@ class SessionState;
*/
class SessionHandler : public framing::FrameHandler::InOutHandler,
public framing::AMQP_ServerOperations::SessionHandler,
+ public framing::AMQP_ClientOperations::SessionHandler,
private boost::noncopyable
{
public:
@@ -81,12 +83,17 @@ class SessionHandler : public framing::FrameHandler::InOutHandler,
const framing::SequenceNumberSet& seenFrameSet);
void highWaterMark(uint32_t lastSentMark);
void solicitAck();
+
+ //extra methods required for assuming client role
+ void attached(const framing::Uuid& sessionId, uint32_t detachedLifetime);
+ void detached();
void assertAttached(const char* method) const;
void assertActive(const char* method) const;
void assertClosed(const char* method) const;
+
Connection& connection;
framing::ChannelHandler channel;
framing::AMQP_ClientProxy proxy;