summaryrefslogtreecommitdiff
path: root/cpp/broker/inc/SessionHandlerImpl.h
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2006-09-22 09:53:47 +0000
committerGordon Sim <gsim@apache.org>2006-09-22 09:53:47 +0000
commit488beb5a2a072afe2be0c7a1f679a5049f3b2e19 (patch)
treeec5d2f70029800a12d3fdd6a91cc0169010a85ac /cpp/broker/inc/SessionHandlerImpl.h
parent6225325010374b21f589e4daba8ddd48564786fa (diff)
downloadqpid-python-488beb5a2a072afe2be0c7a1f679a5049f3b2e19.tar.gz
Added tests for basic_cancel and for handling of invalid channel ids.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@448881 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/broker/inc/SessionHandlerImpl.h')
-rw-r--r--cpp/broker/inc/SessionHandlerImpl.h3
1 files changed, 2 insertions, 1 deletions
diff --git a/cpp/broker/inc/SessionHandlerImpl.h b/cpp/broker/inc/SessionHandlerImpl.h
index 167bf0cc23..549f51f5a1 100644
--- a/cpp/broker/inc/SessionHandlerImpl.h
+++ b/cpp/broker/inc/SessionHandlerImpl.h
@@ -87,6 +87,7 @@ class SessionHandlerImpl : public virtual qpid::io::SessionHandler,
void handleContent(u_int16_t channel, qpid::framing::AMQContentBody::shared_ptr body);
void handleHeartbeat(qpid::framing::AMQHeartbeatBody::shared_ptr body);
+ Channel* getChannel(u_int16_t channel);
/**
* Get named queue, never returns 0.
* @return: named queue or default queue for channel if name=""
@@ -96,7 +97,7 @@ class SessionHandlerImpl : public virtual qpid::io::SessionHandler,
Queue::shared_ptr getQueue(const string& name, u_int16_t channel);
Exchange* findExchange(const string& name);
-
+
public:
SessionHandlerImpl(qpid::io::SessionContext* context, QueueRegistry* queues,
ExchangeRegistry* exchanges, AutoDelete* cleaner, const u_int32_t timeout);