diff options
Diffstat (limited to 'cpp/src/qpid/framing/ChannelAdapter.h')
-rw-r--r-- | cpp/src/qpid/framing/ChannelAdapter.h | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/cpp/src/qpid/framing/ChannelAdapter.h b/cpp/src/qpid/framing/ChannelAdapter.h index 5f92383ee3..1c3f29d762 100644 --- a/cpp/src/qpid/framing/ChannelAdapter.h +++ b/cpp/src/qpid/framing/ChannelAdapter.h @@ -52,7 +52,7 @@ class MethodContext; * Thread safety: OBJECT UNSAFE. Instances must not be called * concurrently. AMQP defines channels to be serialized. */ -class ChannelAdapter : private BodyHandler { +class ChannelAdapter : protected BodyHandler { public: /** *@param output Processed frames are forwarded to this handler. @@ -84,6 +84,10 @@ class ChannelAdapter : private BodyHandler { virtual bool isOpen() const = 0; + RequestId getFirstAckRequest() { return requester.getFirstAckRequest(); } + RequestId getLastAckRequest() { return requester.getLastAckRequest(); } + RequestId getNextSendRequestId() { return requester.getNextId(); } + protected: void assertMethodOk(AMQMethodBody& method) const; void assertChannelOpen() const; @@ -93,13 +97,9 @@ class ChannelAdapter : private BodyHandler { shared_ptr<AMQMethodBody> method, const MethodContext& context) = 0; - RequestId getFirstAckRequest() { return requester.getFirstAckRequest(); } - RequestId getLastAckRequest() { return requester.getLastAckRequest(); } - RequestId getNextSendRequestId() { return requester.getNextId(); } - private: class ChannelAdapterHandler; - friend class ChannelAdapterHandler; + friend class ChannelAdapterHandler; void handleMethod(shared_ptr<AMQMethodBody>); void handleRequest(shared_ptr<AMQRequestBody>); |