X-Git-Url: http://wien.tomnetworks.com/gitweb/?a=blobdiff_plain;f=mcs%2Fclass%2FMono.Messaging.RabbitMQ%2FMono.Messaging.RabbitMQ%2FRabbitMQMessagingProvider.cs;fp=mcs%2Fclass%2FMono.Messaging.RabbitMQ%2FMono.Messaging.RabbitMQ%2FRabbitMQMessagingProvider.cs;h=90aaf7101a5bc2fea16a53781416ff040a2eba2e;hb=95dc3521c07b15316c0087fb5f088e65162077e4;hp=45445659d0ee41ab743f4316069a2c4424d5ce26;hpb=9e3a325d750510b55beacc23db3d79b6d247c835;p=mono.git

diff --git a/mcs/class/Mono.Messaging.RabbitMQ/Mono.Messaging.RabbitMQ/RabbitMQMessagingProvider.cs b/mcs/class/Mono.Messaging.RabbitMQ/Mono.Messaging.RabbitMQ/RabbitMQMessagingProvider.cs
index 45445659d0e..90aaf7101a5 100644
--- a/mcs/class/Mono.Messaging.RabbitMQ/Mono.Messaging.RabbitMQ/RabbitMQMessagingProvider.cs
+++ b/mcs/class/Mono.Messaging.RabbitMQ/Mono.Messaging.RabbitMQ/RabbitMQMessagingProvider.cs
@@ -40,9 +40,8 @@ namespace Mono.Messaging.RabbitMQ {
 
 	public class RabbitMQMessagingProvider : IMessagingProvider {
 		
-		private volatile uint txCounter = 0;
+		private int txCounter = 0;
 		private readonly uint localIp;
-		private static readonly string DEFAULT_REALM = "/data";
 		
 		public RabbitMQMessagingProvider()
 		{
@@ -74,13 +73,14 @@ namespace Mono.Messaging.RabbitMQ {
 		
 		public IMessageQueueTransaction CreateMessageQueueTransaction ()
 		{
-			string txId = localIp.ToString () + (++txCounter).ToString (); 
+			Interlocked.Increment (ref txCounter);
+			string txId = localIp.ToString () + txCounter.ToString (); 
 			return new RabbitMQMessageQueueTransaction (txId);
 		}
 		
 		public void DeleteQueue (QueueReference qRef)
 		{
-			RabbitMQMessageQueue.Delete (DEFAULT_REALM, qRef);
+			RabbitMQMessageQueue.Delete (qRef);
 		}
 		
 		private readonly IDictionary queues = new Hashtable ();