diff options
| author | Gordon Sim <gsim@apache.org> | 2007-08-02 18:09:48 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2007-08-02 18:09:48 +0000 |
| commit | 89aa36d093182e9e191c000504c174663932458f (patch) | |
| tree | 06d7e9a3feb4abdaab74b79c94e4352dfa40adaa /cpp/src/qpid/client/Connection.h | |
| parent | 2290d4ed915f1202bcd6cd50b1a85f27f3eb6cd2 (diff) | |
| download | qpid-python-89aa36d093182e9e191c000504c174663932458f.tar.gz | |
Some restructuring of the client code:
* Introduced three separate 'handlers' for the connection, channel and execution 'layers'.
* Support for asynchronous retrieval of response or completion status.
* Channel methods no longer included in execution layers command id count.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@562212 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/client/Connection.h')
| -rw-r--r-- | cpp/src/qpid/client/Connection.h | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/cpp/src/qpid/client/Connection.h b/cpp/src/qpid/client/Connection.h index 51434fcefd..4d32456c40 100644 --- a/cpp/src/qpid/client/Connection.h +++ b/cpp/src/qpid/client/Connection.h @@ -26,6 +26,7 @@ #include "qpid/QpidError.h" #include "ClientChannel.h" #include "Connector.h" +#include "ConnectionHandler.h" #include "qpid/sys/Mutex.h" #include "qpid/sys/ShutdownHandler.h" #include "qpid/sys/TimeoutHandler.h" @@ -79,17 +80,15 @@ class Connection : public ConnectionForChannel framing::ProtocolVersion version; const uint32_t max_frame_size; ChannelMap channels; + ConnectionHandler handler; Connector defaultConnector; Connector* connector; framing::OutputHandler* out; bool isOpen; sys::Mutex shutdownLock; - Channel channel0; bool debug; void erase(framing::ChannelId); - void channelException( - Channel&, framing::AMQMethodBody*, const QpidError&); void closeChannels(); bool markClosed(); @@ -174,7 +173,7 @@ class Connection : public ConnectionForChannel inline uint32_t getMaxFrameSize(){ return max_frame_size; } /** @return protocol version in use on this connection. */ - framing::ProtocolVersion getVersion() const { return version; } + //framing::ProtocolVersion getVersion() const { return version; } }; }} // namespace qpid::client |