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;
