summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/SessionState.h
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/qpid/broker/SessionState.h')
-rw-r--r--cpp/src/qpid/broker/SessionState.h8
1 files changed, 6 insertions, 2 deletions
diff --git a/cpp/src/qpid/broker/SessionState.h b/cpp/src/qpid/broker/SessionState.h
index 3dcb0a62d4..be79eb0eab 100644
--- a/cpp/src/qpid/broker/SessionState.h
+++ b/cpp/src/qpid/broker/SessionState.h
@@ -72,7 +72,8 @@ class SessionState : public qpid::SessionState,
public framing::FrameHandler::InOutHandler
{
public:
- SessionState(Broker&, SessionHandler&, const SessionId&, const SessionState::Configuration&);
+ SessionState(Broker&, SessionHandler&, const SessionId&,
+ const SessionState::Configuration&, bool delayManagement=false);
~SessionState();
bool isAttached() const { return handler; }
@@ -122,8 +123,11 @@ class SessionState : public qpid::SessionState,
const SessionId& getSessionId() const { return getId(); }
- private:
+ // Used to delay creation of management object for sessions
+ // belonging to inter-broker bridges
+ void addManagementObject();
+ private:
void handleCommand(framing::AMQMethodBody* method, const framing::SequenceNumber& id);
void handleContent(framing::AMQFrame& frame, const framing::SequenceNumber& id);
void enqueued(boost::intrusive_ptr<Message> msg);