diff options
Diffstat (limited to 'cpp/src/qpid/broker/MessageHandlerImpl.cpp')
-rw-r--r-- | cpp/src/qpid/broker/MessageHandlerImpl.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/cpp/src/qpid/broker/MessageHandlerImpl.cpp b/cpp/src/qpid/broker/MessageHandlerImpl.cpp index f586ea92fc..252b465cc5 100644 --- a/cpp/src/qpid/broker/MessageHandlerImpl.cpp +++ b/cpp/src/qpid/broker/MessageHandlerImpl.cpp @@ -134,7 +134,7 @@ MessageHandlerImpl::consume(const MethodContext& context, noLocal ? &connection : 0, &filter); client.ok(context.getRequestId()); // Dispatch messages as there is now a consumer. - queue->dispatch(); + queue->requestDispatch(); } void |