diff options
Diffstat (limited to 'cpp/src/qpid/broker/BrokerQueue.cpp')
| -rw-r--r-- | cpp/src/qpid/broker/BrokerQueue.cpp | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/cpp/src/qpid/broker/BrokerQueue.cpp b/cpp/src/qpid/broker/BrokerQueue.cpp index b26d1d3ed7..cf6beff375 100644 --- a/cpp/src/qpid/broker/BrokerQueue.cpp +++ b/cpp/src/qpid/broker/BrokerQueue.cpp @@ -87,6 +87,11 @@ void Queue::requeue(Message::shared_ptr& msg){ } +void Queue::requestDispatch(){ + serializer.execute(boost::bind(&Queue::dispatch, this)); +} + + bool Queue::dispatch(Message::shared_ptr& msg){ |