You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by jg...@apache.org on 2008/05/27 23:38:15 UTC
svn commit: r660725 - in
/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp:
Connection.cs Transport/Tcp/TcpTransport.cs Transport/TransportFilter.cs
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>