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 2012/04/16 22:02:01 UTC
svn commit: r1326779 -
/activemq/activemq-cpp/branches/activemq-cpp-3.4.x/activemq-cpp/src/main/activemq/core/ActiveMQConnection.cpp
Author: tabish
Date: Mon Apr 16 20:02:00 2012
New Revision: 1326779
URL: http://svn.apache.org/viewvc?rev=1326779&view=rev
Log:
Additional fix for: https://issues.apache.org/jira/browse/AMQCPP-388
Don't trip connection shutdown for the ShutdownInfo command let the transports deal with it.
Modified:
activemq/activemq-cpp/branches/activemq-cpp-3.4.x/activemq-cpp/src/main/activemq/core/ActiveMQConnection.cpp
Modified: activemq/activemq-cpp/branches/activemq-cpp-3.4.x/activemq-cpp/src/main/activemq/core/ActiveMQConnection.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/branches/activemq-cpp-3.4.x/activemq-cpp/src/main/activemq/core/ActiveMQConnection.cpp?rev=1326779&r1=1326778&r2=1326779&view=diff
==============================================================================
--- activemq/activemq-cpp/branches/activemq-cpp-3.4.x/activemq-cpp/src/main/activemq/core/ActiveMQConnection.cpp (original)
+++ activemq/activemq-cpp/branches/activemq-cpp-3.4.x/activemq-cpp/src/main/activemq/core/ActiveMQConnection.cpp Mon Apr 16 20:02:00 2012
@@ -729,17 +729,6 @@ void ActiveMQConnection::onCommand( cons
this->config->brokerInfo =
command.dynamicCast<BrokerInfo>();
this->config->brokerInfoReceived->countDown();
- } else if( command->isShutdownInfo() ) {
-
- try {
- if( !this->isClosed() ) {
- fire( ActiveMQException(
- __FILE__, __LINE__,
- "ActiveMQConnection::onCommand - "
- "Broker closed this connection."));
- }
- } catch( ... ) { /* do nothing */ }
-
} else {
//LOGDECAF_WARN( logger, "Received an unknown command" );
}