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>
