From 27329abdcbe242873fcd004d00b67d37a29bc542 Mon Sep 17 00:00:00 2001 From: "Hiram R. Chirino" Date: Wed, 4 Jan 2006 18:41:16 +0000 Subject: [PATCH] don't log a message when the WireFormatInfo comes in from the other side. git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@365966 13f79535-47bb-0310-9956-ffa450edef68 --- .../activemq/network/DemandForwardingBridge.java | 15 +++++++++++++-- 1 file changed, 13 insertions(+), 2 deletions(-) diff --git a/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridge.java b/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridge.java index b61ade4244..bdd51b09e2 100755 --- a/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridge.java +++ b/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridge.java @@ -38,6 +38,7 @@ import org.apache.activemq.command.ProducerInfo; import org.apache.activemq.command.RemoveInfo; import org.apache.activemq.command.SessionInfo; import org.apache.activemq.command.ShutdownInfo; +import org.apache.activemq.command.WireFormatInfo; import org.apache.activemq.filter.BooleanExpression; import org.apache.activemq.filter.MessageEvaluationContext; import org.apache.activemq.transport.Transport; @@ -222,7 +223,12 @@ public class DemandForwardingBridge implements Bridge { } } } else { - log.warn("Unexpected remote command: "+command); + switch ( command.getDataStructureType() ) { + case WireFormatInfo.DATA_STRUCTURE_TYPE: + break; + default: + log.warn("Unexpected remote command: "+command); + } } } catch (IOException e) { serviceRemoteException(e); @@ -364,7 +370,12 @@ public class DemandForwardingBridge implements Bridge { } } } else { - log.warn("Unexpected local command: "+command); + switch ( command.getDataStructureType() ) { + case WireFormatInfo.DATA_STRUCTURE_TYPE: + break; + default: + log.warn("Unexpected local command: "+command); + } } } catch (IOException e) { serviceLocalException(e);