diff options
| author | Michael Barker <mike@middlesoft.co.uk> | 2009-05-21 10:40:41 +0400 |
|---|---|---|
| committer | Michael Barker <mike@middlesoft.co.uk> | 2009-05-21 10:40:41 +0400 |
| commit | dc15eec37f503a28373be4d32d7b02ffba20e978 (patch) | |
| tree | 13391201ded6b37abe7a37e07538160b72acd26a /mcs/class/Mono.Messaging.RabbitMQ | |
| parent | 75560da8819a4724aac2a37d6eca58228eb53605 (diff) | |
2009-05-21 Michael Barker <mike@middlesoft.co.uk>
Updated to version 1.5.3 of the RabbitMQ libraries.
2009-05-20 Michael Barker <mike@middlesoft.co.uk>
* RabbitMQMessageEnumerator.cs: Removed references to realms & tickets.
* RabbitMQMessageQueue.cs: Removed references to realms & tickets.
svn path=/trunk/mcs/; revision=134509
Diffstat (limited to 'mcs/class/Mono.Messaging.RabbitMQ')
3 files changed, 17 insertions, 17 deletions
diff --git a/mcs/class/Mono.Messaging.RabbitMQ/Mono.Messaging.RabbitMQ/ChangeLog b/mcs/class/Mono.Messaging.RabbitMQ/Mono.Messaging.RabbitMQ/ChangeLog index c76ac7ac199..7cefeaa3aec 100644 --- a/mcs/class/Mono.Messaging.RabbitMQ/Mono.Messaging.RabbitMQ/ChangeLog +++ b/mcs/class/Mono.Messaging.RabbitMQ/Mono.Messaging.RabbitMQ/ChangeLog @@ -47,4 +47,9 @@ 2009-05-19 Michael Barker <mike@middlesoft.co.uk> - * RabbitMQMessageQueue.cs: Added comments.
\ No newline at end of file + * RabbitMQMessageQueue.cs: Added comments. + +2009-05-20 Michael Barker <mike@middlesoft.co.uk> + + * RabbitMQMessageEnumerator.cs: Removed references to realms & tickets. + * RabbitMQMessageQueue.cs: Removed references to realms & tickets.
\ No newline at end of file diff --git a/mcs/class/Mono.Messaging.RabbitMQ/Mono.Messaging.RabbitMQ/RabbitMQMessageEnumerator.cs b/mcs/class/Mono.Messaging.RabbitMQ/Mono.Messaging.RabbitMQ/RabbitMQMessageEnumerator.cs index 30d0ea3542b..93be9fd83fe 100644 --- a/mcs/class/Mono.Messaging.RabbitMQ/Mono.Messaging.RabbitMQ/RabbitMQMessageEnumerator.cs +++ b/mcs/class/Mono.Messaging.RabbitMQ/Mono.Messaging.RabbitMQ/RabbitMQMessageEnumerator.cs @@ -117,10 +117,10 @@ namespace Mono.Messaging.RabbitMQ { if (subscription == null) { IModel ch = Model; - ushort ticket = ch.AccessRequest ("/data"); - string finalName = ch.QueueDeclare (ticket, qRef.Queue, false); + //ushort ticket = ch.AccessRequest ("/data"); + string finalName = ch.QueueDeclare (qRef.Queue, false); - subscription = new Subscription (ch, ticket, finalName); + subscription = new Subscription (ch, finalName); } return subscription; diff --git a/mcs/class/Mono.Messaging.RabbitMQ/Mono.Messaging.RabbitMQ/RabbitMQMessageQueue.cs b/mcs/class/Mono.Messaging.RabbitMQ/Mono.Messaging.RabbitMQ/RabbitMQMessageQueue.cs index 3d5fc614ffb..ea35c687760 100644 --- a/mcs/class/Mono.Messaging.RabbitMQ/Mono.Messaging.RabbitMQ/RabbitMQMessageQueue.cs +++ b/mcs/class/Mono.Messaging.RabbitMQ/Mono.Messaging.RabbitMQ/RabbitMQMessageQueue.cs @@ -209,8 +209,7 @@ namespace Mono.Messaging.RabbitMQ { using (IConnection cn = cf.CreateConnection (qRef.Host)) { using (IModel model = cn.CreateModel ()) { - ushort ticket = model.AccessRequest (realm); - model.QueueDelete (ticket, qRef.Queue, false, false, false); + model.QueueDelete (qRef.Queue, false, false, false); } } } @@ -298,11 +297,10 @@ namespace Mono.Messaging.RabbitMQ { private void Send (IModel model, IMessage msg) { - ushort ticket = model.AccessRequest ("/data"); - string finalName = model.QueueDeclare (ticket, QRef.Queue, true); + string finalName = model.QueueDeclare (QRef.Queue, true); IMessageBuilder mb = helper.WriteMessage (model, msg); - model.BasicPublish (ticket, "", finalName, + model.BasicPublish ("", finalName, (IBasicProperties) mb.GetContentHeader(), mb.GetContentBody ()); } @@ -313,8 +311,7 @@ namespace Mono.Messaging.RabbitMQ { using (IConnection cn = cf.CreateConnection (QRef.Host)) { using (IModel model = cn.CreateModel ()) { - ushort ticket = model.AccessRequest (realm); - model.QueuePurge (ticket, QRef.Queue, false); + model.QueuePurge (QRef.Queue, false); } } } @@ -677,10 +674,9 @@ namespace Mono.Messaging.RabbitMQ { private IMessage Receive (IModel model, int timeout, bool doAck) { - ushort ticket = model.AccessRequest (realm); - string finalName = model.QueueDeclare (ticket, QRef.Queue, false); + string finalName = model.QueueDeclare (QRef.Queue, false); - using (Subscription sub = new Subscription (model, ticket, finalName)) { + using (Subscription sub = new Subscription (model, finalName)) { BasicDeliverEventArgs result; if (sub.Next (timeout, out result)) { IMessage m = helper.ReadMessage (QRef, result); @@ -696,10 +692,9 @@ namespace Mono.Messaging.RabbitMQ { private IMessage Receive (IModel model, int timeout, bool doAck, IsMatch matcher) { - ushort ticket = model.AccessRequest (realm); - string finalName = model.QueueDeclare (ticket, QRef.Queue, false); + string finalName = model.QueueDeclare (QRef.Queue, false); - using (Subscription sub = new Subscription (model, ticket, finalName)) { + using (Subscription sub = new Subscription (model, finalName)) { BasicDeliverEventArgs result; while (sub.Next (timeout, out result)) { |