Attempt to resolve high CPU usage after error by ensuring that the
transport is disposed along with the fire of the local error.
This commit is contained in:
Timothy Bish 2015-08-07 16:21:52 -04:00
parent b52796f794
commit a3c8bee1f0
1 changed files with 2 additions and 2 deletions

View File

@ -348,7 +348,7 @@ public abstract class DemandForwardingBridgeSupport implements NetworkBridge, Br
try {
remoteBrokerInfo = futureRemoteBrokerInfo.get();
if (remoteBrokerInfo == null) {
fireBridgeFailed(new Throwable("remoteBrokerInfo is null"));
serviceLocalException(new Throwable("remoteBrokerInfo is null"));
return;
}
} catch (Exception e) {
@ -359,7 +359,7 @@ public abstract class DemandForwardingBridgeSupport implements NetworkBridge, Br
try {
localBrokerInfo = futureLocalBrokerInfo.get();
if (localBrokerInfo == null) {
fireBridgeFailed(new Throwable("localBrokerInfo is null"));
serviceLocalException(new Throwable("localBrokerInfo is null"));
return;
}