svn commit: r358216 - /incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/tcp/TcpTransportFactory.java

[chirino]

Author: chirino
Date: Tue Dec 20 21:43:16 2005
New Revision: 358216

URL: http://svn.apache.org/viewcvs?rev=358216&view=rev
Log:
only use the wire format negociator if needed.

Modified:
    
incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/tcp/TcpTransportFactory.java

Modified: 
incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/tcp/TcpTransportFactory.java
URL: 
http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/tcp/TcpTransportFactory.java?rev=358216&r1=358215&r2=358216&view=diff
==============================================================================
--- 
incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/tcp/TcpTransportFactory.java
 (original)
+++ 
incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/tcp/TcpTransportFactory.java
 Tue Dec 20 21:43:16 2005
@@ -19,6 +19,7 @@
 package org.activemq.transport.tcp;
 
 import org.activeio.command.WireFormat;
+import org.activemq.openwire.OpenWireFormat;
 import org.activemq.transport.MutexTransport;
 import org.activemq.transport.ResponseCorrelator;
 import org.activemq.transport.Transport;
@@ -68,7 +69,9 @@
         // transport = new InactivityMonitor(transport,
         // temp.getMaxInactivityDuration(), activityMonitor.getReadCounter(),
         // activityMonitor.getWriteCounter());
-        transport = new WireFormatNegotiator(transport, format, 
tcpTransport.getMinmumWireFormatVersion());
+        if( format instanceof OpenWireFormat )
+            transport = new WireFormatNegotiator(transport, format, 
tcpTransport.getMinmumWireFormatVersion());
+        
         transport = new MutexTransport(transport);
         transport = new ResponseCorrelator(transport);
         return transport;