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:32:24 GMT
Updated Branches:
  refs/heads/trunk efd6e7b93 -> 60b733009


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/60b73300
Tree: http://git-wip-us.apache.org/repos/asf/activemq-cpp/tree/60b73300
Diff: http://git-wip-us.apache.org/repos/asf/activemq-cpp/diff/60b73300

Branch: refs/heads/trunk
Commit: 60b7330094114cb4271b53ca21676d88cdf15546
Parents: efd6e7b
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:32:13 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/60b73300/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