diff options
| author | Alan Conway <aconway@apache.org> | 2007-02-17 03:54:15 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2007-02-17 03:54:15 +0000 |
| commit | 56e08f275a1b25aae1be0a0e8f7adaede3f6c184 (patch) | |
| tree | 91efc0d01b73cdb2c3abb8a39d93f82258c3505c /cpp/lib/client/ClientChannel.cpp | |
| parent | f972bfa6c7c9a1b3d5f5fe4753dce7358b6b0215 (diff) | |
| download | qpid-python-56e08f275a1b25aae1be0a0e8f7adaede3f6c184.tar.gz | |
ClientChannel: removed server proxy, not used.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@508706 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/lib/client/ClientChannel.cpp')
| -rw-r--r-- | cpp/lib/client/ClientChannel.cpp | 12 |
1 files changed, 2 insertions, 10 deletions
diff --git a/cpp/lib/client/ClientChannel.cpp b/cpp/lib/client/ClientChannel.cpp index 4dff8a62f7..42e5cf3054 100644 --- a/cpp/lib/client/ClientChannel.cpp +++ b/cpp/lib/client/ClientChannel.cpp @@ -24,7 +24,6 @@ #include <QpidError.h> #include <MethodBodyInstances.h> #include "Connection.h" -#include "AMQP_ServerProxy.h" // FIXME aconway 2007-01-26: Evaluate all throws, ensure consistent // handling of errors that should close the connection or the channel. @@ -49,18 +48,12 @@ Channel::~Channel(){ close(); } -AMQP_ServerProxy& Channel::brokerProxy() { - assert(proxy.get()); - return *proxy; -} - void Channel::open(ChannelId id, Connection& con) { if (isOpen()) THROW_QPID_ERROR(INTERNAL_ERROR, "Attempt to re-open channel "+id); connection = &con; init(id, con, con.getVersion()); // ChannelAdapter initialization. - proxy.reset(new AMQP_ServerProxy(*this)); string oob; if (id != 0) sendAndReceive<ChannelOpenOkBody>(new ChannelOpenBody(version, oob)); @@ -77,12 +70,11 @@ void Channel::protocolInit( string mechanism("PLAIN"); string response = ((char)0) + uid + ((char)0) + pwd; string locale("en_US"); - // TODO aconway 2007-01-26: Move client over to proxy model, - // symmetric with server. ConnectionTuneBody::shared_ptr proposal = sendAndReceive<ConnectionTuneBody>( new ConnectionStartOkBody( - version, responses.getRequestId(), props, mechanism, response, locale)); + version, responses.getRequestId(), props, mechanism, + response, locale)); /** * Assume for now that further challenges will not be required |
