diff options
Diffstat (limited to 'qpid/java')
| -rw-r--r-- | qpid/java/systests/src/main/java/org/apache/qpid/test/client/queue/QueuePolicyTest.java | 3 |
1 files changed, 2 insertions, 1 deletions
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) { |