summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/SessionState.cpp
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2008-02-21 17:40:42 +0000
committerGordon Sim <gsim@apache.org>2008-02-21 17:40:42 +0000
commit3767d7e49e80c268c60ee247b3526b986eb7fc17 (patch)
tree36f0c9487e54705530be26271de7e52676bad524 /cpp/src/qpid/broker/SessionState.cpp
parent5f06a953368f7f41dd8ab94a6775fcd9b5c99792 (diff)
downloadqpid-python-3767d7e49e80c268c60ee247b3526b986eb7fc17.tar.gz
Start moving towards final 0-10 spec:
* marked preview spec as 99-0 to distinguish it from 0-10 (which will now be used for the final version) * modified python client to treat 99-0 as 0-10 for now * modified broker to have two paths for the two different versions: 99-0 uses PreviewConnection, PreviewConnectionHandler and PreviewSessionHandler which are straight copy & pastes of the Connection, ConnectionHandler and SessionHandler now associated with 0-10 (so we can migrate the 0-10 path to the final spec without affecting clients working with the preview version) git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@629883 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/SessionState.cpp')
-rw-r--r--cpp/src/qpid/broker/SessionState.cpp14
1 files changed, 7 insertions, 7 deletions
diff --git a/cpp/src/qpid/broker/SessionState.cpp b/cpp/src/qpid/broker/SessionState.cpp
index 80fafe0386..b6c59cfb3b 100644
--- a/cpp/src/qpid/broker/SessionState.cpp
+++ b/cpp/src/qpid/broker/SessionState.cpp
@@ -20,8 +20,8 @@
*/
#include "SessionState.h"
#include "SessionManager.h"
-#include "SessionHandler.h"
-#include "Connection.h"
+#include "SessionContext.h"
+#include "ConnectionState.h"
#include "Broker.h"
#include "SemanticHandler.h"
#include "qpid/framing/reply_exceptions.h"
@@ -37,7 +37,7 @@ using qpid::management::Manageable;
using qpid::management::Args;
SessionState::SessionState(
- SessionManager* f, SessionHandler* h, uint32_t timeout_, uint32_t ack)
+ SessionManager* f, SessionContext* h, uint32_t timeout_, uint32_t ack)
: framing::SessionState(ack, timeout_ > 0),
factory(f), handler(h), id(true), timeout(timeout_),
broker(h->getConnection().broker),
@@ -76,7 +76,7 @@ SessionState::~SessionState() {
mgmtObject->resourceDestroy ();
}
-SessionHandler* SessionState::getHandler() {
+SessionContext* SessionState::getHandler() {
return handler;
}
@@ -85,7 +85,7 @@ AMQP_ClientProxy& SessionState::getProxy() {
return getHandler()->getProxy();
}
-Connection& SessionState::getConnection() {
+ConnectionState& SessionState::getConnection() {
assert(isAttached());
return getHandler()->getConnection();
}
@@ -100,7 +100,7 @@ void SessionState::detach() {
}
}
-void SessionState::attach(SessionHandler& h) {
+void SessionState::attach(SessionContext& h) {
{
Mutex::ScopedLock l(lock);
handler = &h;
@@ -141,7 +141,7 @@ Manageable::status_t SessionState::ManagementMethod (uint32_t methodId,
case management::Session::METHOD_DETACH :
if (handler != 0)
{
- handler->localSuspend ();
+ handler->detach();
}
status = Manageable::STATUS_OK;
break;