activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r1307451 - /activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/FailoverTransport.cpp
Date Fri, 30 Mar 2012 14:44:57 GMT
Author: tabish
Date: Fri Mar 30 14:44:57 2012
New Revision: 1307451

URL: http://svn.apache.org/viewvc?rev=1307451&view=rev
Log:
fix for: https://issues.apache.org/jira/browse/AMQCPP-391

Modified:
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/FailoverTransport.cpp

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/FailoverTransport.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/FailoverTransport.cpp?rev=1307451&r1=1307450&r2=1307451&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/FailoverTransport.cpp
(original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/FailoverTransport.cpp
Fri Mar 30 14:44:57 2012
@@ -288,6 +288,10 @@ void FailoverTransport::oneway( const Po
                             // Rethrow the exception so it will handled by
                             // the outer catch
                             throw e;
+                        } else {
+                            // Trigger the reconnect since we can't count on inactivity or
+                            // other socket events to trip the failover condition.
+                            handleTransportFailure(e);
                         }
                     }
 



Mime
View raw message