projects
/
mono.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
2009-07-11 Michael Barker <mike@middlesoft.co.uk>
[mono.git]
/
mcs
/
class
/
Mono.Messaging.RabbitMQ
/
Mono.Messaging.RabbitMQ
/
RabbitMQMessagingProvider.cs
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 45445659d0ee41ab743f4316069a2c4424d5ce26..90aaf7101a5bc2fea16a53781416ff040a2eba2e 100644
(file)
--- 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 {
public class RabbitMQMessagingProvider : IMessagingProvider {
- private
volatile u
int txCounter = 0;
+ private int txCounter = 0;
private readonly uint localIp;
private readonly uint localIp;
- private static readonly string DEFAULT_REALM = "/data";
public RabbitMQMessagingProvider()
{
public RabbitMQMessagingProvider()
{
@@
-74,13
+73,14
@@
namespace Mono.Messaging.RabbitMQ {
public IMessageQueueTransaction CreateMessageQueueTransaction ()
{
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)
{
return new RabbitMQMessageQueueTransaction (txId);
}
public void DeleteQueue (QueueReference qRef)
{
- RabbitMQMessageQueue.Delete (
DEFAULT_REALM,
qRef);
+ RabbitMQMessageQueue.Delete (qRef);
}
private readonly IDictionary queues = new Hashtable ();
}
private readonly IDictionary queues = new Hashtable ();