Return-Path: X-Original-To: apmail-activemq-commits-archive@www.apache.org Delivered-To: apmail-activemq-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 5977B10DA5 for ; Wed, 9 Oct 2013 16:33:25 +0000 (UTC) Received: (qmail 94851 invoked by uid 500); 9 Oct 2013 16:33:23 -0000 Delivered-To: apmail-activemq-commits-archive@activemq.apache.org Received: (qmail 94828 invoked by uid 500); 9 Oct 2013 16:33:23 -0000 Mailing-List: contact commits-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@activemq.apache.org Delivered-To: mailing list commits@activemq.apache.org Received: (qmail 94810 invoked by uid 99); 9 Oct 2013 16:33:22 -0000 Received: from tyr.zones.apache.org (HELO tyr.zones.apache.org) (140.211.11.114) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 09 Oct 2013 16:33:22 +0000 Received: by tyr.zones.apache.org (Postfix, from userid 65534) id D976A91319B; Wed, 9 Oct 2013 16:33:19 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: tabish@apache.org To: commits@activemq.apache.org Message-Id: <23ce8f5d76cc4f4db3ba947ec858a877@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: git commit: https://issues.apache.org/jira/browse/AMQCPP-516 Date: Wed, 9 Oct 2013 16:33:19 +0000 (UTC) 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 Authored: Wed Oct 9 12:32:13 2013 -0400 Committer: Timothy Bish 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) {