You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by rg...@apache.org on 2007/01/10 13:50:44 UTC
svn commit: r494801 - in
/incubator/qpid/trunk/qpid/dotnet/Qpid.Client/Client: AMQConnection.cs
AmqChannel.cs
Author: rgreig
Date: Wed Jan 10 04:50:37 2007
New Revision: 494801
URL: http://svn.apache.org/viewvc?view=rev&rev=494801
Log: (empty)
Modified:
incubator/qpid/trunk/qpid/dotnet/Qpid.Client/Client/AMQConnection.cs
incubator/qpid/trunk/qpid/dotnet/Qpid.Client/Client/AmqChannel.cs
Modified: incubator/qpid/trunk/qpid/dotnet/Qpid.Client/Client/AMQConnection.cs
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/dotnet/Qpid.Client/Client/AMQConnection.cs?view=diff&rev=494801&r1=494800&r2=494801
==============================================================================
--- incubator/qpid/trunk/qpid/dotnet/Qpid.Client/Client/AMQConnection.cs (original)
+++ incubator/qpid/trunk/qpid/dotnet/Qpid.Client/Client/AMQConnection.cs Wed Jan 10 04:50:37 2007
@@ -386,6 +386,7 @@
public void Start()
{
CheckNotClosed();
+
if (!_started)
{
foreach (DictionaryEntry lde in _sessions)
@@ -400,7 +401,16 @@
public void Stop()
{
CheckNotClosed();
- throw new NotImplementedException();
+
+ if (_started)
+ {
+ foreach (DictionaryEntry lde in _sessions)
+ {
+ AmqChannel s = (AmqChannel) lde.Value;
+ s.Stop();
+ }
+ _started = false;
+ }
}
public IConnectionListener ConnectionListener
Modified: incubator/qpid/trunk/qpid/dotnet/Qpid.Client/Client/AmqChannel.cs
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/dotnet/Qpid.Client/Client/AmqChannel.cs?view=diff&rev=494801&r1=494800&r2=494801
==============================================================================
--- incubator/qpid/trunk/qpid/dotnet/Qpid.Client/Client/AmqChannel.cs (original)
+++ incubator/qpid/trunk/qpid/dotnet/Qpid.Client/Client/AmqChannel.cs Wed Jan 10 04:50:37 2007
@@ -608,6 +608,14 @@
dispatcherThread.Start();
}
+ internal void Stop()
+ {
+ if (_dispatcher != null)
+ {
+ _dispatcher.StopDispatcher();
+ }
+ }
+
internal void RegisterConsumer(string consumerTag, IMessageConsumer consumer)
{
_consumers[consumerTag] = consumer;