diff options
Diffstat (limited to 'cpp/src/qpid/client/ClientChannel.cpp')
-rw-r--r-- | cpp/src/qpid/client/ClientChannel.cpp | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/cpp/src/qpid/client/ClientChannel.cpp b/cpp/src/qpid/client/ClientChannel.cpp index d1cc4734eb..cc2b7aedc8 100644 --- a/cpp/src/qpid/client/ClientChannel.cpp +++ b/cpp/src/qpid/client/ClientChannel.cpp @@ -181,8 +181,8 @@ bool Channel::get(Message& msg, const Queue& queue, AckMode ackMode) { if (response.isA<BasicGetEmptyBody>()) { return false; } else { - ReceivedContent::shared_ptr content = gets.pop(); - content->populate(msg); + FrameSet::shared_ptr content = gets.pop(); + msg.populate(*content); return true; } } @@ -232,13 +232,13 @@ void Channel::join() { void Channel::run() { try { while (true) { - ReceivedContent::shared_ptr content = session->get(); + FrameSet::shared_ptr content = session->get(); //need to dispatch this to the relevant listener: if (content->isA<BasicDeliverBody>()) { ConsumerMap::iterator i = consumers.find(content->as<BasicDeliverBody>()->getConsumerTag()); if (i != consumers.end()) { Message msg; - content->populate(msg); + msg.populate(*content); i->second.listener->received(msg); } else { QPID_LOG(warning, "Dropping message for unrecognised consumer: " << content->getMethod()); |