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();
}
