Author: tabish
Date: Sun Nov 16 12:46:40 2008
New Revision: 718112
URL: http://svn.apache.org/viewvc?rev=718112&view=rev
Log:
http://issues.apache.org/activemq/browse/AMQCPP-196
Turn off use of the Async Transport in favor of async sends from the producer.
Modified:
activemq/activemq-cpp/trunk/src/main/activemq/transport/TransportBuilder.cpp
activemq/activemq-cpp/trunk/src/main/activemq/transport/filters/AsyncSendTransport.h
Modified:
activemq/activemq-cpp/trunk/src/main/activemq/transport/TransportBuilder.cpp
URL:
http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/transport/TransportBuilder.cpp?rev=718112&r1=718111&r2=718112&view=diff
==============================================================================
---
activemq/activemq-cpp/trunk/src/main/activemq/transport/TransportBuilder.cpp
(original)
+++
activemq/activemq-cpp/trunk/src/main/activemq/transport/TransportBuilder.cpp
Sun Nov 16 12:46:40 2008
@@ -55,15 +55,6 @@
properties,
transport );
- // If async sends are enabled, wrap the transport with a
AsyncSendTransport
- // do this before the response correlator so that all commands go out
on the
- // send message queue, otherwise messages could get sent out of order.
- if( properties.getProperty( "transport.useAsyncSend", "false" ) ==
"true" ) {
- // Create the Transport for response correlator
- transport = this->createTransport(
- "transport.filters.AsyncSendTransport", properties, transport
);
- }
-
// Create the Transport for response correlator
transport = this->createTransport(
"transport.filters.ResponseCorrelator", properties, transport );
Modified:
activemq/activemq-cpp/trunk/src/main/activemq/transport/filters/AsyncSendTransport.h
URL:
http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/transport/filters/AsyncSendTransport.h?rev=718112&r1=718111&r2=718112&view=diff
==============================================================================
---
activemq/activemq-cpp/trunk/src/main/activemq/transport/filters/AsyncSendTransport.h
(original)
+++
activemq/activemq-cpp/trunk/src/main/activemq/transport/filters/AsyncSendTransport.h
Sun Nov 16 12:46:40 2008
@@ -27,6 +27,9 @@
namespace transport{
namespace filters{
+ /**
+ * @Deprecated
+ */
class AMQCPP_API AsyncSendTransport : public TransportFilter,
public decaf::lang::Runnable {
private:
