You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by js...@apache.org on 2006/03/03 11:36:33 UTC
svn commit: r382754 -
/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransportFactory.java
Author: jstrachan
Date: Fri Mar 3 02:36:32 2006
New Revision: 382754
URL: http://svn.apache.org/viewcvs?rev=382754&view=rev
Log:
removed old comment
Modified:
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransportFactory.java
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransportFactory.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransportFactory.java?rev=382754&r1=382753&r2=382754&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransportFactory.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransportFactory.java Fri Mar 3 02:36:32 2006
@@ -64,11 +64,6 @@
transport = new TransportLogger(transport);
}
- // TODO: missing inactivity monitor
- // transport = new InactivityMonitor(transport,
- // temp.getMaxInactivityDuration(), activityMonitor.getReadCounter(),
- // activityMonitor.getWriteCounter());
-
if( format instanceof OpenWireFormat )
transport = new WireFormatNegotiator(transport, format, tcpTransport.getMinmumWireFormatVersion());
@@ -88,10 +83,6 @@
transport = new TransportLogger(transport);
}
- // TODO: missing inactivity monitor
- // transport = new InactivityMonitor(transport,
- // temp.getMaxInactivityDuration(), activityMonitor.getReadCounter(),
- // activityMonitor.getWriteCounter());
transport = new WireFormatNegotiator(transport, format, tcpTransport.getMinmumWireFormatVersion());
if( tcpTransport.getMaxInactivityDuration() > 0 ) {
transport = new InactivityMonitor(transport, tcpTransport.getMaxInactivityDuration());