activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r358216 - /incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/tcp/TcpTransportFactory.java
Date Wed, 21 Dec 2005 05:43:21 GMT
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;



Mime
View raw message