activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r805543 - /activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Connection.cs
Date Tue, 18 Aug 2009 19:21:04 GMT
Author: tabish
Date: Tue Aug 18 19:21:03 2009
New Revision: 805543

URL: http://svn.apache.org/viewvc?rev=805543&view=rev
Log:
Add Handlers for the Interrupted and Resumed events.

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

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Connection.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Connection.cs?rev=805543&r1=805542&r2=805543&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Connection.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Connection.cs Tue Aug
18 19:21:03 2009
@@ -60,6 +60,8 @@
 			this.transport = transport;
 			this.transport.Command = new CommandHandler(OnCommand);
 			this.transport.Exception = new ExceptionHandler(OnException);
+			this.transport.Interrupted = new InterruptedHandler(OnTransportInterrupted);
+			this.transport.Resumed = new ResumedHandler(OnTransportResumed);
 		}
 
 		~Connection()
@@ -536,6 +538,16 @@
 			}
 		}
 
+		protected void OnTransportInterrupted(ITransport sender)
+		{
+			Tracer.Debug("Transport has been Interrupted.");			
+		}
+
+		protected void OnTransportResumed(ITransport sender)
+		{
+			Tracer.Debug("Transport has resumed normal operation.");			
+		}
+
 		internal void OnSessionException(Session sender, Exception exception)
 		{
 			if(ExceptionListener != null)



Mime
View raw message