git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1439395 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Gary Tully 2013-01-28 13:19:10 +00:00
parent 0bfa0cdf1a
commit 9988fff773
1 changed files with 3 additions and 3 deletions

View File

@ -96,9 +96,9 @@ public class NetworkBridgeFilter implements DataStructure, BooleanExpression {
if (message.isAdvisory()) { if (message.isAdvisory()) {
if (consumerInfo != null && consumerInfo.isNetworkSubscription()) { if (consumerInfo != null && consumerInfo.isNetworkSubscription()) {
// they will be interpreted by the bridge leading to dup commands // they will be interpreted by the bridge leading to dup commands
//if (LOG.isTraceEnabled()) { if (LOG.isTraceEnabled()) {
LOG.error("not propagating advisory to network sub: " + consumerInfo.getConsumerId() + ", message: "+ message); LOG.trace("not propagating advisory to network sub: " + consumerInfo.getConsumerId() + ", message: "+ message);
//} }
return false; return false;
} else if ( message.getDataStructure() != null && message.getDataStructure().getDataStructureType() == CommandTypes.CONSUMER_INFO) { } else if ( message.getDataStructure() != null && message.getDataStructure().getDataStructureType() == CommandTypes.CONSUMER_INFO) {
ConsumerInfo info = (ConsumerInfo)message.getDataStructure(); ConsumerInfo info = (ConsumerInfo)message.getDataStructure();