diff options
Diffstat (limited to 'cpp/src/qpid/broker/DeliverableMessage.cpp')
| -rw-r--r-- | cpp/src/qpid/broker/DeliverableMessage.cpp | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/cpp/src/qpid/broker/DeliverableMessage.cpp b/cpp/src/qpid/broker/DeliverableMessage.cpp index a713f306a8..9a3752d71c 100644 --- a/cpp/src/qpid/broker/DeliverableMessage.cpp +++ b/cpp/src/qpid/broker/DeliverableMessage.cpp @@ -29,9 +29,11 @@ DeliverableMessage::DeliverableMessage(Message::shared_ptr& _msg) : msg(_msg) void DeliverableMessage::deliverTo(Queue::shared_ptr& queue) { queue->deliver(msg); + delivered = true; } Message& DeliverableMessage::getMessage() { return *msg; } + |