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 2011/01/24 21:41:26 UTC
svn commit: r1062960 - in
/activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Util:
MessageDispatchChannel.cs ThreadUtil.cs
Author: jgomes
Date: Mon Jan 24 20:41:26 2011
New Revision: 1062960
URL: http://svn.apache.org/viewvc?rev=1062960&view=rev
Log:
Stub out WaitHandle.WaitAny() with platform wrapper implementation in ThreadUtil.WaitAny().
Modified:
activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Util/MessageDispatchChannel.cs
activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Util/ThreadUtil.cs
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=1062960&r1=1062959&r2=1062960&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 24 20:41:26 2011
@@ -170,7 +170,7 @@ namespace Apache.NMS.Stomp.Util
{
this.mutex.ReleaseMutex();
this.waiter.Reset();
- WaitHandle.WaitAny(this.waiters, (int)timeout.TotalMilliseconds, false);
+ ThreadUtil.WaitAny(this.waiters, (int)timeout.TotalMilliseconds, false);
this.mutex.WaitOne();
}
Modified: activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Util/ThreadUtil.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Util/ThreadUtil.cs?rev=1062960&r1=1062959&r2=1062960&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Util/ThreadUtil.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Util/ThreadUtil.cs Mon Jan 24 20:41:26 2011
@@ -33,5 +33,14 @@ namespace Apache.NMS.Stomp.Util
shutdownEvent.WaitOne(timeout, false);
#endif
}
+
+ public static void WaitAny(WaitHandle[] waitHandles, int millisecondsTimeout, bool exitContext)
+ {
+#if NETCF
+ // TODO: Implement .NET CF version of WaitAny().
+#else
+ WaitHandle.WaitAny(waitHandles, millisecondsTimeout, exitContext);
+#endif
+ }
}
}