Add one minute timeout to RabbitMQ integration test
Project: http://git-wip-us.apache.org/repos/asf/brooklyn-library/repo Commit: http://git-wip-us.apache.org/repos/asf/brooklyn-library/commit/c65577e9 Tree: http://git-wip-us.apache.org/repos/asf/brooklyn-library/tree/c65577e9 Diff: http://git-wip-us.apache.org/repos/asf/brooklyn-library/diff/c65577e9 Branch: refs/heads/0.5.0 Commit: c65577e9eb7447ac8a9403f53f6a63bac9403bb5 Parents: 4b5d145 Author: Andrew Kennedy <[email protected]> Authored: Wed Apr 24 13:09:07 2013 +0100 Committer: Andrew Kennedy <[email protected]> Committed: Wed Apr 24 13:09:07 2013 +0100 ---------------------------------------------------------------------- .../brooklyn/entity/messaging/rabbit/RabbitIntegrationTest.groovy | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/brooklyn-library/blob/c65577e9/software/messaging/src/test/java/brooklyn/entity/messaging/rabbit/RabbitIntegrationTest.groovy ---------------------------------------------------------------------- diff --git a/software/messaging/src/test/java/brooklyn/entity/messaging/rabbit/RabbitIntegrationTest.groovy b/software/messaging/src/test/java/brooklyn/entity/messaging/rabbit/RabbitIntegrationTest.groovy index 94aeb0f..1ad3597 100644 --- a/software/messaging/src/test/java/brooklyn/entity/messaging/rabbit/RabbitIntegrationTest.groovy +++ b/software/messaging/src/test/java/brooklyn/entity/messaging/rabbit/RabbitIntegrationTest.groovy @@ -101,7 +101,7 @@ public class RabbitIntegrationTest { QueueingConsumer queueConsumer = new QueueingConsumer(consumer); consumer.basicConsume(queue, true, queueConsumer); - QueueingConsumer.Delivery delivery = queueConsumer.nextDelivery(); + QueueingConsumer.Delivery delivery = queueConsumer.nextDelivery(60 * 1000l); // one minute timeout assertEquals(delivery.body, content) } finally { producer?.close()
