Author: tabish
Date: Thu Nov 13 06:03:45 2008
New Revision: 713726
URL: http://svn.apache.org/viewvc?rev=713726&view=rev
Log:
https://issues.apache.org/activemq/browse/AMQCPP-199
Fix ordering problem when creating and sending the ProducerInfo command in
openwire.
Modified:
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/OpenWireConnector.cpp
Modified:
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/OpenWireConnector.cpp
URL:
http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/OpenWireConnector.cpp?rev=713726&r1=713725&r2=713726&view=diff
==============================================================================
---
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/OpenWireConnector.cpp
(original)
+++
activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/OpenWireConnector.cpp
Thu Nov 13 06:03:45 2008
@@ -618,11 +618,12 @@
options.getProperty( "producer.dispatchAsync", "false" )) );
}
- // Send the message to the broker.
- syncRequest( producerInfo.get() );
-
+ // Store the completed ProducerInfo Command in the Producer object.
producer->setProducerInfo( producerInfo.release() );
+ // Send the message to the broker.
+ syncRequest( producer->getProducerInfo() );
+
return producer.release();
}
AMQ_CATCH_RETHROW( ConnectorException )
