activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r1371368 - /activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Transport/InactivityMonitor.cs
Date Thu, 09 Aug 2012 18:41:41 GMT
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);



Mime
View raw message