diff options
author | Gordon Sim <gsim@apache.org> | 2006-09-22 09:53:47 +0000 |
---|---|---|
committer | Gordon Sim <gsim@apache.org> | 2006-09-22 09:53:47 +0000 |
commit | 488beb5a2a072afe2be0c7a1f679a5049f3b2e19 (patch) | |
tree | ec5d2f70029800a12d3fdd6a91cc0169010a85ac /cpp/broker/inc/SessionHandlerImpl.h | |
parent | 6225325010374b21f589e4daba8ddd48564786fa (diff) | |
download | qpid-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.h | 3 |
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); |