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()
{
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 ();