diff options
| author | Rajith Muditha Attapattu <rajith@apache.org> | 2010-09-08 14:28:26 +0000 |
|---|---|---|
| committer | Rajith Muditha Attapattu <rajith@apache.org> | 2010-09-08 14:28:26 +0000 |
| commit | c175f640b72bc79a0a8ad519163082932377a556 (patch) | |
| tree | 66b65a1e944e04f794687ff30922a632fd697619 /qpid/java | |
| parent | f83c155657ebd11272ad890df9d42c096e1ad50b (diff) | |
| download | qpid-python-c175f640b72bc79a0a8ad519163082932377a556.tar.gz | |
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
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) { |