You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2010/01/11 22:32:48 UTC
svn commit: r898072 - in
/activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp:
Threads/DedicatedTaskRunner.cs Util/MessageDispatchChannel.cs
Author: tabish
Date: Mon Jan 11 21:32:48 2010
New Revision: 898072
URL: http://svn.apache.org/viewvc?rev=898072&view=rev
Log:
port the MessageDispatchChannel to build on .NET CF 2.0 and above
Modified:
activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Threads/DedicatedTaskRunner.cs
activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Util/MessageDispatchChannel.cs
Modified: activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Threads/DedicatedTaskRunner.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Threads/DedicatedTaskRunner.cs?rev=898072&r1=898071&r2=898072&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Threads/DedicatedTaskRunner.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Threads/DedicatedTaskRunner.cs Mon Jan 11 21:32:48 2010
@@ -63,7 +63,7 @@
if(Thread.CurrentThread != this.theThread && !this.terminated)
{
Monitor.Exit(this.mutex);
- this.isShutdown.WaitOne(timeout.Milliseconds);
+ this.isShutdown.WaitOne((int)timeout.Milliseconds, false);
}
else
{
Modified: activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Util/MessageDispatchChannel.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Util/MessageDispatchChannel.cs?rev=898072&r1=898071&r2=898072&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Util/MessageDispatchChannel.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Util/MessageDispatchChannel.cs Mon Jan 11 21:32:48 2010
@@ -169,7 +169,7 @@
if( timeout != TimeSpan.Zero && !Closed && ( Empty || !Running ) )
{
this.mutex.ReleaseMutex();
- this.waiter.WaitOne(timeout, false);
+ this.waiter.WaitOne((int)timeout.TotalMilliseconds, false);
this.mutex.WaitOne();
}