Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

removed old comment 

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382754 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
James Strachan 2006-03-03 10:36:32 +00:00
parent bed10aac1e
commit 4dad3fc833
1 changed files with 0 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransportFactory.java
View File

@ -64,11 +64,6 @@ public class TcpTransportFactory extends TransportFactory {
transport = new TransportLogger(transport); transport = new TransportLogger(transport);
} }
// TODO: missing inactivity monitor
// transport = new InactivityMonitor(transport,
// temp.getMaxInactivityDuration(), activityMonitor.getReadCounter(),
// activityMonitor.getWriteCounter());
if( format instanceof OpenWireFormat ) if( format instanceof OpenWireFormat )
transport = new WireFormatNegotiator(transport, format, tcpTransport.getMinmumWireFormatVersion()); transport = new WireFormatNegotiator(transport, format, tcpTransport.getMinmumWireFormatVersion());
@ -88,10 +83,6 @@ public class TcpTransportFactory extends TransportFactory {
transport = new TransportLogger(transport); 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()); transport = new WireFormatNegotiator(transport, format, tcpTransport.getMinmumWireFormatVersion());
if( tcpTransport.getMaxInactivityDuration() > 0 ) { if( tcpTransport.getMaxInactivityDuration() > 0 ) {
transport = new InactivityMonitor(transport, tcpTransport.getMaxInactivityDuration()); transport = new InactivityMonitor(transport, tcpTransport.getMaxInactivityDuration());