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 2009/12/23 21:31:12 UTC
svn commit: r893622 -
/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/InactivityMonitor.cs
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);