diff options
Diffstat (limited to 'cpp/src/qpid/broker/BrokerMessage.cpp')
-rw-r--r-- | cpp/src/qpid/broker/BrokerMessage.cpp | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/cpp/src/qpid/broker/BrokerMessage.cpp b/cpp/src/qpid/broker/BrokerMessage.cpp index 21b56869d4..d192b09a63 100644 --- a/cpp/src/qpid/broker/BrokerMessage.cpp +++ b/cpp/src/qpid/broker/BrokerMessage.cpp @@ -78,10 +78,10 @@ void BasicMessage::deliver(ChannelAdapter& channel, const string& consumerTag, uint64_t deliveryTag, uint32_t framesize) { - channel.send( + channel.send(make_shared_ptr( new BasicDeliverBody( channel.getVersion(), consumerTag, deliveryTag, - getRedelivered(), getExchange(), getRoutingKey())); + getRedelivered(), getExchange(), getRoutingKey()))); sendContent(channel, framesize); } @@ -92,12 +92,12 @@ void BasicMessage::sendGetOk(ChannelAdapter& channel, uint64_t deliveryTag, uint32_t framesize) { - channel.send( + channel.send(make_shared_ptr( new BasicGetOkBody( channel.getVersion(), responseTo, deliveryTag, getRedelivered(), getExchange(), - getRoutingKey(), messageCount)); + getRoutingKey(), messageCount))); sendContent(channel, framesize); } |