From 80406d0fb680239a0141b81fb0b9f20d20c9b1e1 Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Fri, 27 Jul 2007 15:44:52 +0000 Subject: Use execution layer to acknowledge messages. Turn off 0-9 framing of requests and responses. Some refactoring around message delivery. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@560285 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/broker/BrokerAdapter.cpp | 11 +++++------ 1 file changed, 5 insertions(+), 6 deletions(-) (limited to 'cpp/src/qpid/broker/BrokerAdapter.cpp') diff --git a/cpp/src/qpid/broker/BrokerAdapter.cpp b/cpp/src/qpid/broker/BrokerAdapter.cpp index 376108193a..8edf448bc4 100644 --- a/cpp/src/qpid/broker/BrokerAdapter.cpp +++ b/cpp/src/qpid/broker/BrokerAdapter.cpp @@ -20,8 +20,7 @@ #include "BrokerAdapter.h" #include "BrokerChannel.h" #include "Connection.h" -#include "ConsumeAdapter.h" -#include "GetAdapter.h" +#include "DeliveryToken.h" #include "qpid/framing/AMQMethodBody.h" #include "qpid/Exception.h" @@ -325,8 +324,8 @@ void BrokerAdapter::BasicHandlerImpl::consume(uint16_t /*ticket*/, //need to generate name here, so we have it for the adapter (it is //also version specific behaviour now) if (newTag.empty()) newTag = tagGenerator.generate(); - channel.consume(std::auto_ptr(new ConsumeAdapter(adapter, newTag, connection.getFrameMax())), - newTag, queue, !noAck, exclusive, noLocal ? &connection : 0, &fields); + DeliveryToken::shared_ptr token(BasicMessage::createConsumeToken(newTag)); + channel.consume(token, newTag, queue, !noAck, exclusive, noLocal ? &connection : 0, &fields); if(!nowait) client.consumeOk(newTag); @@ -357,8 +356,8 @@ void BrokerAdapter::BasicHandlerImpl::publish(uint16_t /*ticket*/, void BrokerAdapter::BasicHandlerImpl::get(uint16_t /*ticket*/, const string& queueName, bool noAck){ Queue::shared_ptr queue = getQueue(queueName); - GetAdapter out(adapter, queue, "", connection.getFrameMax()); - if(!channel.get(out, queue, !noAck)){ + DeliveryToken::shared_ptr token(BasicMessage::createGetToken(queue)); + if(!channel.get(token, queue, !noAck)){ string clusterId;//not used, part of an imatix hack client.getEmpty(clusterId); -- cgit v1.2.1