diff options
Diffstat (limited to 'cpp/src/qpid/broker/MessageHandlerImpl.cpp')
-rw-r--r-- | cpp/src/qpid/broker/MessageHandlerImpl.cpp | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/cpp/src/qpid/broker/MessageHandlerImpl.cpp b/cpp/src/qpid/broker/MessageHandlerImpl.cpp index c728a800ab..70f7c3b8ec 100644 --- a/cpp/src/qpid/broker/MessageHandlerImpl.cpp +++ b/cpp/src/qpid/broker/MessageHandlerImpl.cpp @@ -162,10 +162,9 @@ MessageHandlerImpl::transfer(const framing::MethodContext& context) MessageTransferBody::shared_ptr transfer( boost::shared_polymorphic_downcast<MessageTransferBody>( context.methodBody)); - RequestId requestId = context.getRequestId(); if (transfer->getBody().isInline()) { - MessageMessage::shared_ptr message(new MessageMessage(&connection, requestId, transfer)); + MessageMessage::shared_ptr message(new MessageMessage(&connection, 0, transfer)); channel.handleInlineTransfer(message); } else { throw ConnectionException(540, "References no longer supported"); |