summaryrefslogtreecommitdiff
path: root/cpp/lib/client/ClientChannel.cpp
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2007-02-17 03:54:15 +0000
committerAlan Conway <aconway@apache.org>2007-02-17 03:54:15 +0000
commit56e08f275a1b25aae1be0a0e8f7adaede3f6c184 (patch)
tree91efc0d01b73cdb2c3abb8a39d93f82258c3505c /cpp/lib/client/ClientChannel.cpp
parentf972bfa6c7c9a1b3d5f5fe4753dce7358b6b0215 (diff)
downloadqpid-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.cpp12
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