Spring/spring-amqp
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Added validation for null values.

Browse Source
This commit is contained in:
Tomas Lukosius
2011-04-24 07:31:04 +03:00
parent ecdb0d5717
commit 7c98c8d0b7
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
spring-rabbit/src/test/java/org/springframework/amqp/rabbit/core/RabbitTemplateIntegrationTests.java
View File

@@ -293,6 +293,7 @@ public class RabbitTemplateIntegrationTests {
Message message = new Message("test-message".getBytes(), new MessageProperties());
Message reply = template.sendAndReceive(message);
assertEquals(new String(message.getBody()), new String(received.get(1000, TimeUnit.MILLISECONDS).getBody()));
assertNotNull("Reply is expected", reply);
assertEquals(new String(message.getBody()), new String(reply.getBody()));
// Message was consumed so nothing left on queue
reply = template.receive();
@@ -324,6 +325,7 @@ public class RabbitTemplateIntegrationTests {
Message message = new Message("test-message".getBytes(), new MessageProperties());
Message reply = template.sendAndReceive(ROUTE, message);
assertEquals(new String(message.getBody()), new String(received.get(1000, TimeUnit.MILLISECONDS).getBody()));
assertNotNull("Reply is expected", reply);
assertEquals(new String(message.getBody()), new String(reply.getBody()));
// Message was consumed so nothing left on queue
reply = template.receive(ROUTE);
@@ -355,6 +357,7 @@ public class RabbitTemplateIntegrationTests {
Message message = new Message("test-message".getBytes(), new MessageProperties());
Message reply = template.sendAndReceive("", ROUTE, message);
assertEquals(new String(message.getBody()), new String(received.get(1000, TimeUnit.MILLISECONDS).getBody()));
assertNotNull("Reply is expected", reply);
assertEquals(new String(message.getBody()), new String(reply.getBody()));
// Message was consumed so nothing left on queue
reply = template.receive(ROUTE);