2 // Test.Mono.Messaging.RabbitMQ
5 // Michael Barker (mike@middlesoft.co.uk)
7 // (C) 2008 Michael Barker
11 // Permission is hereby granted, free of charge, to any person obtaining
12 // a copy of this software and associated documentation files (the
13 // "Software"), to deal in the Software without restriction, including
14 // without limitation the rights to use, copy, modify, merge, publish,
15 // distribute, sublicense, and/or sell copies of the Software, and to
16 // permit persons to whom the Software is furnished to do so, subject to
17 // the following conditions:
19 // The above copyright notice and this permission notice shall be
20 // included in all copies or substantial portions of the Software.
22 // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
23 // EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
24 // MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
25 // NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
26 // LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
27 // OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
28 // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
32 using System.Messaging;
34 using NUnit.Framework;
36 namespace MonoTests.Mono.Messaging.RabbitMQ
39 public class SelectorTest
43 public void SelectById ()
45 String body = "Foo-" + DateTime.Now.ToString ();
46 Message s1 = new Message (body, new BinaryMessageFormatter());
47 MessageQueue q = MQUtil.GetQueue (@".\private$\selector-queue-1");
52 Message r1 = q.ReceiveById (id);
54 Assert.AreEqual (body, r1.Body, "Unable to ReceiveById correctly");
58 [ExpectedException (typeof (InvalidOperationException))]
59 public void SelectByIdNotFound ()
61 String body = "Foo-" + DateTime.Now.ToString();
62 Message s1 = new Message(body, new BinaryMessageFormatter());
63 MessageQueue q = MQUtil.GetQueue(@".\private$\selector-queue-2");
69 Message r1 = q.ReceiveById (id);
76 public void SelectByCorrelationId ()
78 string correlationId = Guid.NewGuid () + "\\0";
79 String body = "Foo-" + DateTime.Now.ToString();
80 Message s1 = new Message(body, new BinaryMessageFormatter());
81 s1.CorrelationId = correlationId;
82 MessageQueue q = MQUtil.GetQueue(@".\private$\selector-queue-3");
85 Message r1 = q.ReceiveByCorrelationId (correlationId);
87 Assert.AreEqual (body, r1.Body, "Unable to ReceiveByCorrelationId correctly");
91 [ExpectedException (typeof (InvalidOperationException))]
92 public void SelectByCorrelationIdNotFound ()
94 string correlationId = Guid.NewGuid() + "\\0";
95 String body = "Foo-" + DateTime.Now.ToString();
96 Message s1 = new Message(body, new BinaryMessageFormatter());
97 s1.CorrelationId = correlationId;
98 MessageQueue q = MQUtil.GetQueue(@".\private$\selector-queue-4");
102 Message r1 = q.ReceiveByCorrelationId ("fail!");
109 public void SelectByIdWithTimeout ()
111 String body = "Foo-" + DateTime.Now.ToString();
112 Message s1 = new Message(body, new BinaryMessageFormatter());
113 MessageQueue q = MQUtil.GetQueue(@".\private$\selector-queue-5");
118 Message r1 = q.ReceiveById (id, new TimeSpan (0, 0, 2));
120 Assert.AreEqual (body, r1.Body, "Unable to ReceiveById correctly");
124 public void SelectByCorrelationIdWithTimeout ()
126 string correlationId = Guid.NewGuid() + "\\0";
127 String body = "Foo-" + DateTime.Now.ToString();
128 Message s1 = new Message(body, new BinaryMessageFormatter());
129 s1.CorrelationId = correlationId;
130 MessageQueue q = MQUtil.GetQueue(@".\private$\selector-queue-3");
133 Message r1 = q.ReceiveByCorrelationId (correlationId, new TimeSpan (0, 0, 2));
135 Assert.AreEqual (body, r1.Body, "Unable to ReceiveByCorrelationId correctly");