activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject git commit: https://issues.apache.org/jira/browse/AMQCPP-516
Date Wed, 09 Oct 2013 16:33:19 GMT
Updated Branches:
  refs/heads/3.8.x 8eaedcb3b -> 3f26f1071


https://issues.apache.org/jira/browse/AMQCPP-516


Project: http://git-wip-us.apache.org/repos/asf/activemq-cpp/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-cpp/commit/3f26f107
Tree: http://git-wip-us.apache.org/repos/asf/activemq-cpp/tree/3f26f107
Diff: http://git-wip-us.apache.org/repos/asf/activemq-cpp/diff/3f26f107

Branch: refs/heads/3.8.x
Commit: 3f26f1071fbe0512eb22989364567ac06494c1a3
Parents: 8eaedcb
Author: Timothy Bish <tabish121@gmai.com>
Authored: Wed Oct 9 12:32:13 2013 -0400
Committer: Timothy Bish <tabish121@gmai.com>
Committed: Wed Oct 9 12:33:04 2013 -0400

----------------------------------------------------------------------
 .../main/activemq/transport/failover/FailoverTransport.cpp   | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq-cpp/blob/3f26f107/activemq-cpp/src/main/activemq/transport/failover/FailoverTransport.cpp
----------------------------------------------------------------------
diff --git a/activemq-cpp/src/main/activemq/transport/failover/FailoverTransport.cpp b/activemq-cpp/src/main/activemq/transport/failover/FailoverTransport.cpp
index dc99c96..954c211 100644
--- a/activemq-cpp/src/main/activemq/transport/failover/FailoverTransport.cpp
+++ b/activemq-cpp/src/main/activemq/transport/failover/FailoverTransport.cpp
@@ -722,11 +722,11 @@ void FailoverTransport::handleTransportFailure(const decaf::lang::Exception&
err
 
             // Notify before we attempt to reconnect so that the consumers have a chance
             // to cleanup their state.
-            if (this->impl->transportListener != NULL) {
-                this->impl->transportListener->transportInterrupted();
-            }
-
             if (reconnectOk) {
+                if (this->impl->transportListener != NULL) {
+                    this->impl->transportListener->transportInterrupted();
+                }
+
                 this->impl->updated->removeURI(failedUri);
                 this->impl->taskRunner->wakeup();
             } else if (!this->impl->closed) {


Mime
View raw message