diff options
| author | Alan Conway <aconway@apache.org> | 2007-08-14 14:29:07 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2007-08-14 14:29:07 +0000 |
| commit | b3ddadd9b15088afecf1f9774d2004258b164258 (patch) | |
| tree | 3318dd9b06101ad7d025ccbc80a5b0127846a681 /cpp/src/qpid/framing/ChannelAdapter.h | |
| parent | 0f0e942cab53ac81c5adf6fbd5b7cc3a403161e8 (diff) | |
| download | qpid-python-b3ddadd9b15088afecf1f9774d2004258b164258.tar.gz | |
Deleted following files that are obsolete for 0-10:
src/qpid/framing/AMQRequestBody.cpp
src/qpid/framing/AMQRequestBody.h
src/qpid/framing/AMQResponseBody.cpp
src/qpid/framing/AMQResponseBody.h
src/qpid/framing/Correlator.cpp
src/qpid/framing/Correlator.h
src/qpid/framing/MethodContext.cpp
src/qpid/framing/Requester.cpp
src/qpid/framing/Requester.h
src/qpid/framing/Responder.cpp
src/qpid/framing/Responder.h
Made changes to support their deletion.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@565770 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/framing/ChannelAdapter.h')
| -rw-r--r-- | cpp/src/qpid/framing/ChannelAdapter.h | 19 |
1 files changed, 3 insertions, 16 deletions
diff --git a/cpp/src/qpid/framing/ChannelAdapter.h b/cpp/src/qpid/framing/ChannelAdapter.h index a7c9c61640..84a626c864 100644 --- a/cpp/src/qpid/framing/ChannelAdapter.h +++ b/cpp/src/qpid/framing/ChannelAdapter.h @@ -27,9 +27,7 @@ #include "qpid/shared_ptr.h" #include "BodyHandler.h" -#include "Requester.h" -#include "Responder.h" -#include "Correlator.h" +#include "ProtocolVersion.h" #include "amqp_types.h" #include "FrameHandler.h" @@ -37,6 +35,7 @@ namespace qpid { namespace framing { class MethodContext; +class OutputHandler; /** * Base class for client and broker channels. @@ -71,19 +70,12 @@ class ChannelAdapter : protected BodyHandler { /** * Send a frame. *@param body Body of the frame. - *@param action optional action to execute when we receive a - *response to this frame. Ignored if body is not a Request. *@return If body is a request, the ID assigned else 0. */ - virtual RequestId send(shared_ptr<AMQBody> body, - Correlator::Action action=Correlator::Action()); + virtual RequestId send(shared_ptr<AMQBody> body); 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; @@ -98,14 +90,9 @@ class ChannelAdapter : protected BodyHandler { friend class ChannelAdapterHandler; void handleMethod(shared_ptr<AMQMethodBody>); - void handleRequest(shared_ptr<AMQRequestBody>); - void handleResponse(shared_ptr<AMQResponseBody>); ChannelId id; ProtocolVersion version; - Requester requester; - Responder responder; - Correlator correlator; FrameHandler::Chains handlers; }; |
