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 2009/11/04 21:21:27 UTC
svn commit: r832868 -
/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQConnection.cpp
Author: tabish
Date: Wed Nov 4 20:21:27 2009
New Revision: 832868
URL: http://svn.apache.org/viewvc?rev=832868&view=rev
Log:
Patch the code to prevent the new 5.3 broker from thinking the client had timed out.
Modified:
activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQConnection.cpp
Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQConnection.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQConnection.cpp?rev=832868&r1=832867&r2=832868&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQConnection.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQConnection.cpp Wed Nov 4 20:21:27 2009
@@ -486,11 +486,8 @@
command.dynamicCast<BrokerInfo>();
} else if( command->isKeepAliveInfo() ) {
- if( command->isResponseRequired() ) {
- command->setResponseRequired( false );
-
- oneway( command );
- }
+ // Return the command to prevent the broker from timing us out.
+ oneway( command );
} else if( command->isShutdownInfo() ) {