You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2012/08/09 20:41:41 UTC
svn commit: r1371368 -
/activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Transport/InactivityMonitor.cs
Author: tabish
Date: Thu Aug 9 18:41:41 2012
New Revision: 1371368
URL: http://svn.apache.org/viewvc?rev=1371368&view=rev
Log:
https://issues.apache.org/jira/browse/AMQNET-384
small fix to inactivity monitor to ensure the read and write times are set correctly.
Modified:
activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Transport/InactivityMonitor.cs
Modified: activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Transport/InactivityMonitor.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Transport/InactivityMonitor.cs?rev=1371368&r1=1371367&r2=1371368&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Transport/InactivityMonitor.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Transport/InactivityMonitor.cs Thu Aug 9 18:41:41 2012
@@ -315,7 +315,7 @@ namespace Apache.NMS.Stomp.Transport
{
readCheckTime =
Math.Max(
- localWireFormatInfo.MaxInactivityDuration,
+ localWireFormatInfo.ReadCheckInterval,
remoteWireFormatInfo.WriteCheckInterval);
this.asyncErrorTask = new AsyncSignalReadErrorkTask(this, next.RemoteAddress);
@@ -326,12 +326,12 @@ namespace Apache.NMS.Stomp.Transport
if(remoteWireFormatInfo.Version > 1.0)
{
writeCheckTime =
- Math.Max(localWireFormatInfo.MaxInactivityDuration,
+ Math.Max(localWireFormatInfo.WriteCheckInterval,
remoteWireFormatInfo.ReadCheckInterval);
}
else
{
- writeCheckTime = localWireFormatInfo.MaxInactivityDuration;
+ writeCheckTime = localWireFormatInfo.WriteCheckInterval;
}
this.asyncWriteTask = new AsyncWriteTask(this);