You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2008/11/16 21:46:41 UTC
svn commit: r718112 - in
/activemq/activemq-cpp/trunk/src/main/activemq/transport:
TransportBuilder.cpp filters/AsyncSendTransport.h
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: