activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r718112 - in /activemq/activemq-cpp/trunk/src/main/activemq/transport: TransportBuilder.cpp filters/AsyncSendTransport.h
Date Sun, 16 Nov 2008 20:46:41 GMT
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:



Mime
View raw message