diff options
author | Alan Conway <aconway@apache.org> | 2008-02-01 18:02:42 +0000 |
---|---|---|
committer | Alan Conway <aconway@apache.org> | 2008-02-01 18:02:42 +0000 |
commit | 4db96f7ad47c69982cdc6cf7b5e5c47b00f1144b (patch) | |
tree | d125438eb115c0b21171b27d17e6ca1f57622542 /cpp/src/qpid/broker/SessionState.h | |
parent | ae3201b50554b23f52132635f2e852a4fc78617e (diff) | |
download | qpid-python-4db96f7ad47c69982cdc6cf7b5e5c47b00f1144b.tar.gz |
Cluster code fixed for changes in codebase.
- Using SessionManager::Observer
- Better ais test setup, only need to be member of ais group.
- Update cluster_client
- SessionState holds handler chains.
- Cluster frames include next handler ptr.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@617582 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/SessionState.h')
-rw-r--r-- | cpp/src/qpid/broker/SessionState.h | 17 |
1 files changed, 7 insertions, 10 deletions
diff --git a/cpp/src/qpid/broker/SessionState.h b/cpp/src/qpid/broker/SessionState.h index c8c32a046d..bc1b974eaa 100644 --- a/cpp/src/qpid/broker/SessionState.h +++ b/cpp/src/qpid/broker/SessionState.h @@ -58,7 +58,7 @@ class Connection; * themselves have state. */ class SessionState : public framing::SessionState, - public framing::FrameHandler::InOutHandler, + public framing::FrameHandler::Chains, public sys::OutputControl, public management::Manageable { @@ -90,18 +90,15 @@ class SessionState : public framing::SessionState, management::Manageable::status_t ManagementMethod (uint32_t methodId, management::Args& args); - protected: - void handleIn(framing::AMQFrame&); - void handleOut(framing::AMQFrame&); - - private: - // SessionManager creates sessions. - SessionState(SessionManager&, - SessionHandler& out, + // Normally SessionManager creates sessions. + SessionState(SessionManager*, + SessionHandler* out, uint32_t timeout, uint32_t ackInterval); - SessionManager& factory; + + private: + SessionManager* factory; SessionHandler* handler; framing::Uuid id; uint32_t timeout; |