From a804510d81ade0594a75b5c9b8765cafcc233245 Mon Sep 17 00:00:00 2001 From: Kim van der Riet Date: Mon, 16 Jul 2012 13:54:11 +0000 Subject: QPID-3858: Refactor to tidy up several class design issues git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/asyncstore@1362039 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/asyncStore/OperationQueue.cpp | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) (limited to 'cpp/src/qpid/asyncStore/OperationQueue.cpp') diff --git a/cpp/src/qpid/asyncStore/OperationQueue.cpp b/cpp/src/qpid/asyncStore/OperationQueue.cpp index 0b7f58bd6c..dd4e7c1343 100644 --- a/cpp/src/qpid/asyncStore/OperationQueue.cpp +++ b/cpp/src/qpid/asyncStore/OperationQueue.cpp @@ -24,6 +24,8 @@ #include "OperationQueue.h" #include "qpid/broker/AsyncResultHandle.h" +#include "qpid/broker/AsyncResultHandleImpl.h" +#include "qpid/log/Statement.h" namespace qpid { namespace asyncStore { @@ -42,7 +44,6 @@ OperationQueue::~OperationQueue() void OperationQueue::submit(boost::shared_ptr op) { -//std::cout << "--> OperationQueue::submit() op=" << op->getOpStr() << std::endl << std::flush; m_opQueue.push(op); } @@ -52,7 +53,6 @@ OperationQueue::handle(const OperationQueue::OpQueue::Batch& e) { try { for (OpQueue::Batch::const_iterator i = e.begin(); i != e.end(); ++i) { -//std::cout << "<-- OperationQueue::handle() Op=" << (*i)->getOpStr() << std::endl << std::flush; boost::shared_ptr bc = (*i)->getBrokerContext(); if (bc) { qpid::broker::AsyncResultQueue* const arq = bc->getAsyncResultQueue(); @@ -64,9 +64,9 @@ OperationQueue::handle(const OperationQueue::OpQueue::Batch& e) } } } catch (const std::exception& e) { - std::cerr << "qpid::asyncStore::OperationQueue: Exception thrown processing async op: " << e.what() << std::endl; + QPID_LOG(error, "qpid::asyncStore::OperationQueue: Exception thrown processing async op: " << e.what()); } catch (...) { - std::cerr << "qpid::asyncStore::OperationQueue: Unknown exception thrown processing async op" << std::endl; + QPID_LOG(error, "qpid::asyncStore::OperationQueue: Unknown exception thrown processing async op"); } return e.end(); } -- cgit v1.2.1