From a6303894d7f9a24df4a691af3ce94647c033ebff Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Tue, 24 Jul 2007 14:27:31 +0000 Subject: Initial support for latest approved 0-10 xml (with some transitional hacks included). git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@559059 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/client/BasicMessageChannel.cpp | 10 ++-------- 1 file changed, 2 insertions(+), 8 deletions(-) (limited to 'cpp/src/qpid/client/BasicMessageChannel.cpp') diff --git a/cpp/src/qpid/client/BasicMessageChannel.cpp b/cpp/src/qpid/client/BasicMessageChannel.cpp index a1aacdee4e..70cb473426 100644 --- a/cpp/src/qpid/client/BasicMessageChannel.cpp +++ b/cpp/src/qpid/client/BasicMessageChannel.cpp @@ -197,11 +197,6 @@ void BasicMessageChannel::handle(boost::shared_ptr method) { msg.setRedelivered(deliver->getRedelivered()); return; } - case BasicReturnBody::METHOD_ID: { - incoming.openReference(BASIC_REF); - incoming.createMessage(BASIC_RETURN, BASIC_REF); - return; - } case BasicConsumeOkBody::METHOD_ID: { Mutex::ScopedLock l(lock); BasicConsumeOkBody::shared_ptr consumeOk = @@ -332,10 +327,9 @@ void BasicMessageChannel::setReturnedMessageHandler(ReturnedMessageHandler* hand } void BasicMessageChannel::setQos(){ - channel.sendAndReceive( - make_shared_ptr(new BasicQosBody(channel.version, 0, channel.getPrefetch(), false))); + channel.send(make_shared_ptr(new BasicQosBody(channel.version, 0, channel.getPrefetch(), false))); if(channel.isTransactional()) - channel.sendAndReceive(make_shared_ptr(new TxSelectBody(channel.version))); + channel.send(make_shared_ptr(new TxSelectBody(channel.version))); } }} // namespace qpid::client -- cgit v1.2.1