activemq-commits mailing list archives

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

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

Remove remaining debug code.

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=893622&r1=893621&r2=893622&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 20:31:12 2009
@@ -126,14 +126,12 @@
             if(!commandSent.Value)
             {
                 Tracer.Debug("No Message sent since last write check. Sending a KeepAliveInfo");
-                Console.WriteLine("No Message sent since last write check. Sending a KeepAliveInfo");
                 this.asyncWriteTask.IsPending = true;
                 this.asyncTasks.Wakeup();
             }
             else
             {
                 Tracer.Debug("Message sent since last write check. Resetting flag");
-                Console.WriteLine("Message sent since last write check. Resetting flag");
             }
 
             commandSent.Value = false;
@@ -162,7 +160,6 @@
             if(!commandReceived.Value)
             {
                 Tracer.Debug("No message received since last read check! Sending an InactivityException!");
-                Console.WriteLine("No message received since last read check! Sending an
InactivityException!");
                 this.asyncErrorTask.IsPending = true;
                 this.asyncTasks.Wakeup();
             }
@@ -273,7 +270,6 @@
             if(failed.CompareAndSet(false, true))
             {
                 Tracer.Debug("Exception received in the Inactivity Monitor: " + command.ToString());
-                Console.WriteLine("Exception received in the Inactivity Monitor: " + command.Message);
                 StopMonitorThreads();
                 base.OnException(sender, command);
             }
@@ -351,7 +347,7 @@
                     shutdownEvent.WaitOne(TimeSpan.FromMilliseconds(2000));
                     this.writeCheckTimer.Dispose(shutdownEvent);
                     shutdownEvent.WaitOne(TimeSpan.FromMilliseconds(2000));
-                    
+
 					this.asyncTasks.Shutdown();
                     this.asyncTasks = null;
                     this.asyncWriteTask = null;
@@ -384,7 +380,6 @@
             {
                 if(this.pending.CompareAndSet(true, false) && this.parent.monitorStarted.Value)
                 {
-                    Console.WriteLine("AsyncSignalReadErrorkTask - Sending Pending Read Error");
                     IOException ex = new IOException("Channel was inactive for too long:
" + remote);
                     this.parent.OnException(parent, ex);
                 }
@@ -416,7 +411,6 @@
                 {
                     try
                     {
-                        Console.WriteLine("AsyncWriteTask - Sending Pending KeepAlive");
                         KeepAliveInfo info = new KeepAliveInfo();
                         info.ResponseRequired = this.parent.keepAliveResponseRequired.Value;
                         this.parent.Oneway(info);



Mime
View raw message