From c175f640b72bc79a0a8ad519163082932377a556 Mon Sep 17 00:00:00 2001 From: Rajith Muditha Attapattu Date: Wed, 8 Sep 2010 14:28:26 +0000 Subject: Added a failure path for testRejectPolicy if an exception is not thrown. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@995065 13f79535-47bb-0310-9956-ffa450edef68 --- .../main/java/org/apache/qpid/test/client/queue/QueuePolicyTest.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) (limited to 'qpid/java') diff --git a/qpid/java/systests/src/main/java/org/apache/qpid/test/client/queue/QueuePolicyTest.java b/qpid/java/systests/src/main/java/org/apache/qpid/test/client/queue/QueuePolicyTest.java index 468fd7e994..268e879745 100644 --- a/qpid/java/systests/src/main/java/org/apache/qpid/test/client/queue/QueuePolicyTest.java +++ b/qpid/java/systests/src/main/java/org/apache/qpid/test/client/queue/QueuePolicyTest.java @@ -45,7 +45,7 @@ public class QueuePolicyTest extends QpidBrokerTestCase MessageConsumer consumer = ssn.createConsumer(dest); MessageProducer prod = ssn.createProducer(ssn.createQueue("ADDR:amq.direct/test")); - for (int i=0; i<50; i++) + for (int i=0; i<6; i++) { prod.send(ssn.createMessage()); } @@ -54,6 +54,7 @@ public class QueuePolicyTest extends QpidBrokerTestCase { prod.send(ssn.createMessage()); ((AMQSession)ssn).sync(); + fail("The client did not receive an exception after exceeding the queue limit"); } catch (AMQException e) { -- cgit v1.2.1