activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gtu...@apache.org
Subject activemq git commit: [AMQ-4082] - ensure masked exception is report in the log on missing broker info from local or remote transports
Date Tue, 15 Nov 2016 13:24:09 GMT
Repository: activemq
Updated Branches:
  refs/heads/master 105128a92 -> 253726674


[AMQ-4082] - ensure masked exception is report in the log on missing broker info from local
or remote transports


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

Branch: refs/heads/master
Commit: 2537266740452dbf85454c4f6236569be9231cdc
Parents: 105128a
Author: gtully <gary.tully@gmail.com>
Authored: Tue Nov 15 13:23:54 2016 +0000
Committer: gtully <gary.tully@gmail.com>
Committed: Tue Nov 15 13:23:54 2016 +0000

----------------------------------------------------------------------
 .../org/apache/activemq/network/DemandForwardingBridgeSupport.java | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq/blob/25372667/activemq-broker/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
----------------------------------------------------------------------
diff --git a/activemq-broker/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
b/activemq-broker/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
index a849f62..f7dc745 100644
--- a/activemq-broker/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
@@ -221,6 +221,7 @@ public abstract class DemandForwardingBridgeSupport implements NetworkBridge,
Br
                 @Override
                 public void onException(IOException error) {
                     if (!futureLocalBrokerInfo.isDone()) {
+                        LOG.info("error with pending local brokerInfo on: " + localBroker,
error);
                         futureLocalBrokerInfo.cancel(true);
                         return;
                     }
@@ -239,6 +240,7 @@ public abstract class DemandForwardingBridgeSupport implements NetworkBridge,
Br
                 @Override
                 public void onException(IOException error) {
                     if (!futureRemoteBrokerInfo.isDone()) {
+                        LOG.info("error with pending remote brokerInfo on: " + remoteBroker,
error);
                         futureRemoteBrokerInfo.cancel(true);
                         return;
                     }


Mime
View raw message