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

1 files changed, 6 insertions, 5 deletions

diff --git a/cpp/src/qpid/broker/AsyncResultQueueImpl.cpp b/cpp/src/qpid/broker/AsyncResultQueueImpl.cpp
index 62c7ed33d9..ab408be9ca 100644
--- a/cpp/src/qpid/broker/AsyncResultQueueImpl.cpp
+++ b/cpp/src/qpid/broker/AsyncResultQueueImpl.cpp
@@ -21,9 +21,12 @@
  * \file AsyncResultQueueImpl.cpp
  */
 
-#include "AsyncResultHandle.h"
 #include "AsyncResultQueueImpl.h"
 
+#include "AsyncResultHandle.h"
+
+#include "qpid/log/Statement.h"
+
 namespace qpid {
 namespace broker {
 
@@ -41,7 +44,6 @@ AsyncResultQueueImpl::~AsyncResultQueueImpl()
 void
 AsyncResultQueueImpl::submit(boost::shared_ptr<AsyncResultHandle> arh)
 {
-//std::cout << "==> AsyncResultQueueImpl::submit() errNo=" << arh->getErrNo() << " errMsg=\"" << arh->getErrMsg() << "\"" << std::endl << std::flush;
     m_resQueue.push(arh);
 }
 
@@ -51,15 +53,14 @@ AsyncResultQueueImpl::handle(const ResultQueue::Batch& e)
 {
     try {
         for (ResultQueue::Batch::const_iterator i = e.begin(); i != e.end(); ++i) {
-//std::cout << "<== AsyncResultQueueImpl::handle() errNo=" << (*i)->getErrNo() << " errMsg=\"" << (*i)->getErrMsg() << "\"" << std::endl << std::flush;
             if ((*i)->isValid()) {
                 (*i)->invokeAsyncResultCallback();
             }
         }
     } catch (const std::exception& e) {
-        std::cerr << "qpid::broker::AsyncResultQueueImpl: Exception thrown processing async result: " << e.what() << std::endl;
+        QPID_LOG(error, "Exception thrown processing async result: " << e.what());
     } catch (...) {
-        std::cerr << "qpid::broker::AsyncResultQueueImpl: Unknown exception thrown processing async result" << std::endl;
+        QPID_LOG(error, "Unknown exception thrown processing async result");
     }
     return e.end();
 }