You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by gt...@apache.org on 2016/11/15 13:24:09 UTC
activemq git commit: [AMQ-4082] - ensure masked exception is report
in the log on missing broker info from local or remote transports
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 <ga...@gmail.com>
Authored: Tue Nov 15 13:23:54 2016 +0000
Committer: gtully <ga...@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;
}