summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/AsyncResultQueueImpl.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/qpid/broker/AsyncResultQueueImpl.cpp')
-rw-r--r--cpp/src/qpid/broker/AsyncResultQueueImpl.cpp9
1 files changed, 3 insertions, 6 deletions
diff --git a/cpp/src/qpid/broker/AsyncResultQueueImpl.cpp b/cpp/src/qpid/broker/AsyncResultQueueImpl.cpp
index ab408be9ca..9f8188f8c7 100644
--- a/cpp/src/qpid/broker/AsyncResultQueueImpl.cpp
+++ b/cpp/src/qpid/broker/AsyncResultQueueImpl.cpp
@@ -36,21 +36,18 @@ AsyncResultQueueImpl::AsyncResultQueueImpl(const boost::shared_ptr<qpid::sys::Po
m_resQueue.start();
}
-AsyncResultQueueImpl::~AsyncResultQueueImpl()
-{
+AsyncResultQueueImpl::~AsyncResultQueueImpl() {
m_resQueue.stop();
}
void
-AsyncResultQueueImpl::submit(boost::shared_ptr<AsyncResultHandle> arh)
-{
+AsyncResultQueueImpl::submit(boost::shared_ptr<AsyncResultHandle> arh) {
m_resQueue.push(arh);
}
// private
AsyncResultQueueImpl::ResultQueue::Batch::const_iterator
-AsyncResultQueueImpl::handle(const ResultQueue::Batch& e)
-{
+AsyncResultQueueImpl::handle(const ResultQueue::Batch& e) {
try {
for (ResultQueue::Batch::const_iterator i = e.begin(); i != e.end(); ++i) {
if ((*i)->isValid()) {