From deff1e751c9d0c1baec2d0b7a9e5b88d5668a861 Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Wed, 11 Oct 2006 08:24:42 +0000 Subject: Implementation of basic_get. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@462729 13f79535-47bb-0310-9956-ffa450edef68 --- qpid/cpp/broker/src/Message.cpp | 16 +++++++++++++++- 1 file changed, 15 insertions(+), 1 deletion(-) (limited to 'qpid/cpp/broker/src/Message.cpp') diff --git a/qpid/cpp/broker/src/Message.cpp b/qpid/cpp/broker/src/Message.cpp index a44eeaab59..b0e5d16b77 100644 --- a/qpid/cpp/broker/src/Message.cpp +++ b/qpid/cpp/broker/src/Message.cpp @@ -59,10 +59,24 @@ void Message::redeliver(){ } void Message::deliver(OutputHandler* out, int channel, - string& consumerTag, u_int64_t deliveryTag, + const string& consumerTag, u_int64_t deliveryTag, u_int32_t framesize){ out->send(new AMQFrame(channel, new BasicDeliverBody(consumerTag, deliveryTag, redelivered, exchange, routingKey))); + sendContent(out, channel, framesize); +} + +void Message::sendGetOk(OutputHandler* out, + int channel, + u_int32_t messageCount, + u_int64_t deliveryTag, + u_int32_t framesize){ + + out->send(new AMQFrame(channel, new BasicGetOkBody(deliveryTag, redelivered, exchange, routingKey, messageCount))); + sendContent(out, channel, framesize); +} + +void Message::sendContent(OutputHandler* out, int channel, u_int32_t framesize){ AMQBody::shared_ptr headerBody = static_pointer_cast(header); out->send(new AMQFrame(channel, headerBody)); for(content_iterator i = content.begin(); i != content.end(); i++){ -- cgit v1.2.1