activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r893606 - /activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/InactivityMonitor.cs
Date Wed, 23 Dec 2009 19:21:28 GMT
Author: tabish
Date: Wed Dec 23 19:21:27 2009
New Revision: 893606

URL: http://svn.apache.org/viewvc?rev=893606&view=rev
Log:
https://issues.apache.org/activemq/browse/AMQNET-212

Update to inactivity monitor to handle the dispose call and ensure the Timers and TaskRunners
are shutdown.  Remove some of the debug code now.

Modified:
    activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/InactivityMonitor.cs

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/InactivityMonitor.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/InactivityMonitor.cs?rev=893606&r1=893605&r2=893606&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/InactivityMonitor.cs
(original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/InactivityMonitor.cs
Wed Dec 23 19:21:27 2009
@@ -93,7 +93,23 @@
             : base(next)
         {
             Tracer.Debug("Creating Inactivity Monitor");
-            Console.WriteLine("Creating Inactivity Monitor");
+        }
+
+        ~InactivityMonitor()
+        {
+            Dispose(false);
+        }
+
+        protected override void Dispose(bool disposing)
+        {
+            if(disposing)
+            {
+                // get rid of unmanaged stuff
+            }
+
+            StopMonitorThreads();
+
+            base.Dispose(disposing);
         }
 
         #region WriteCheck Related
@@ -102,11 +118,8 @@
         /// </summary>
         public void WriteCheck(object state)
         {
-            Console.WriteLine("Entered WriteCheck");
-
             if(this.inWrite.Value || this.failed.Value)
             {
-                Console.WriteLine("In write or already failed.");
                 return;
             }
 
@@ -130,13 +143,11 @@
         #region ReadCheck Related
         public void ReadCheck(object state)
         {
-            Console.WriteLine("Entered ReadCheck");
             DateTime now = DateTime.Now;
             TimeSpan elapsed = now - this.lastReadCheckTime;
 
             if(!AllowReadCheck(elapsed))
             {
-                Console.WriteLine("A read check is not yet allowed.");
                 return;
             }
 
@@ -145,7 +156,6 @@
             if(this.inRead.Value || this.failed.Value)
             {
                 Tracer.Debug("A receive is in progress or already failed.");
-                Console.WriteLine("A receive is in progress");
                 return;
             }
 



Mime
View raw message