diff options
Diffstat (limited to 'cpp/src/qpid/client/ClientChannel.cpp')
| -rw-r--r-- | cpp/src/qpid/client/ClientChannel.cpp | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/cpp/src/qpid/client/ClientChannel.cpp b/cpp/src/qpid/client/ClientChannel.cpp index 9eca2903cc..424ff97ea1 100644 --- a/cpp/src/qpid/client/ClientChannel.cpp +++ b/cpp/src/qpid/client/ClientChannel.cpp @@ -220,7 +220,9 @@ void Channel::cancel(const std::string& tag, bool synch) { bool Channel::get(Message& msg, const Queue& queue, AckMode ackMode) { AMQMethodBody::shared_ptr request(new BasicGetBody(version, 0, queue.getName(), ackMode)); + Response response = session->send(request, true); + session->flush(); if (response.isA<BasicGetEmptyBody>()) { return false; } else { |