activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r688530 - /activemq/activemq-cpp/trunk/src/main/activemq/transport/filters/AsyncSendTransport.cpp
Date Sun, 24 Aug 2008 17:16:05 GMT
Author: tabish
Date: Sun Aug 24 10:16:05 2008
New Revision: 688530

URL: http://svn.apache.org/viewvc?rev=688530&view=rev
Log:
https://issues.apache.org/activemq/browse/AMQCPP-189

Adding a max pending message limit property to this AsyncSendTransport so that it can be configured
not to fill all available memory if the broker stalls.

Modified:
    activemq/activemq-cpp/trunk/src/main/activemq/transport/filters/AsyncSendTransport.cpp

Modified: activemq/activemq-cpp/trunk/src/main/activemq/transport/filters/AsyncSendTransport.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/transport/filters/AsyncSendTransport.cpp?rev=688530&r1=688529&r2=688530&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/transport/filters/AsyncSendTransport.cpp
(original)
+++ activemq/activemq-cpp/trunk/src/main/activemq/transport/filters/AsyncSendTransport.cpp
Sun Aug 24 10:16:05 2008
@@ -40,7 +40,6 @@
 AsyncSendTransport::AsyncSendTransport( Transport* next, unsigned int maxBacklog, bool own
)
  : TransportFilter( next, own ) {
 
-    std::cout << "Async Transport using max Backlog of :" << maxBacklog <<
std::endl;
     this->closed = true;
     this->asyncThread = NULL;
     this->maxBacklog = maxBacklog;
@@ -67,8 +66,7 @@
         // send it.
         synchronized( &msgQueue ) {
 
-            while( msgQueue.size() >= this->maxBacklog ) {
-                std::cout << "Max Backlog reached" << std::endl;
+            while( this->maxBacklog != 0 && msgQueue.size() >= this->maxBacklog
) {
                 msgQueue.wait();
             }
 



Mime
View raw message