activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jgo...@apache.org
Subject svn commit: r660725 - in /activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp: Connection.cs Transport/Tcp/TcpTransport.cs Transport/TransportFilter.cs
Date Tue, 27 May 2008 21:38:15 GMT
Author: jgomes
Date: Tue May 27 14:38:15 2008
New Revision: 660725

URL: http://svn.apache.org/viewvc?rev=660725&view=rev
Log:
[AMQNET-86] Added IsStarted property to IStartable interface.
Fixes [AMQNET-86]. (See https://issues.apache.org/activemq/browse/AMQNET-86)

Modified:
    activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Connection.cs
    activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/Tcp/TcpTransport.cs
    activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/TransportFilter.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=660725&r1=660724&r2=660725&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 May
27 14:38:15 2008
@@ -63,11 +63,6 @@
 		public event ExceptionListener ExceptionListener;
 
 
-		public bool IsStarted
-		{
-			get { return started.Value; }
-		}
-
 		#region Properties
 
 		/// <summary>
@@ -108,6 +103,15 @@
 		}
 
 		/// <summary>
+		/// This property determines if the asynchronous message delivery of incoming
+		/// messages has been started for this connection.
+		/// </summary>
+		public bool IsStarted
+		{
+			get { return started.Value; }
+		}
+
+		/// <summary>
 		/// Temporarily stop asynchronous delivery of inbound messages for this connection.
 		/// The sending of outbound messages is unaffected.
 		/// </summary>

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/Tcp/TcpTransport.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/Tcp/TcpTransport.cs?rev=660725&r1=660724&r2=660725&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/Tcp/TcpTransport.cs
(original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/Tcp/TcpTransport.cs
Tue May 27 14:38:15 2008
@@ -85,6 +85,20 @@
 				}
 			}
         }
+
+		/// <summary>
+		/// Property IsStarted
+		/// </summary>
+		public bool IsStarted
+		{
+			get
+			{
+				lock(initLock)
+				{
+					return started;
+				}
+			}
+		}
         
         public void Oneway(Command command)
         {

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/TransportFilter.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/TransportFilter.cs?rev=660725&r1=660724&r2=660725&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/TransportFilter.cs
(original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/TransportFilter.cs
Tue May 27 14:38:15 2008
@@ -85,7 +85,18 @@
 				throw new InvalidOperationException ("exception cannot be null when Start is called.");
 			this.next.Start();
 		}
-		
+
+		/// <summary>
+		/// Property IsStarted
+		/// </summary>
+		public bool IsStarted
+		{
+			get
+			{
+				return this.next.IsStarted;
+			}
+		}
+
 		/// <summary>
 		/// Method Dispose
 		/// </summary>



Mime
View raw message