diff options
Diffstat (limited to 'cpp/src/qpid/broker/BrokerQueue.cpp')
| -rw-r--r-- | cpp/src/qpid/broker/BrokerQueue.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/cpp/src/qpid/broker/BrokerQueue.cpp b/cpp/src/qpid/broker/BrokerQueue.cpp index 1a13a31a5e..d96622cd4f 100644 --- a/cpp/src/qpid/broker/BrokerQueue.cpp +++ b/cpp/src/qpid/broker/BrokerQueue.cpp @@ -126,7 +126,7 @@ bool Queue::acquire(const QueuedMessage& msg) { void Queue::requestDispatch(Consumer* c, bool sync){ if (!c || c->preAcquires()) { if (sync) { - serializer.dispatch(); + dispatch(); } else { serializer.execute(dispatchCallback); } |