You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by kw...@apache.org on 2016/10/04 08:10:25 UTC
svn commit: r1763242 -
/qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/client/MaxDeliveryCountTest.java
Author: kwall
Date: Tue Oct 4 08:10:25 2016
New Revision: 1763242
URL: http://svn.apache.org/viewvc?rev=1763242&view=rev
Log:
NO-JIRA: [System Tests] Make MaxDeliveryCountTest use qpid.test_receive_timeout
Modified:
qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/client/MaxDeliveryCountTest.java
Modified: qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/client/MaxDeliveryCountTest.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/client/MaxDeliveryCountTest.java?rev=1763242&r1=1763241&r2=1763242&view=diff
==============================================================================
--- qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/client/MaxDeliveryCountTest.java (original)
+++ qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/client/MaxDeliveryCountTest.java Tue Oct 4 08:10:25 2016
@@ -335,7 +335,7 @@ public class MaxDeliveryCountTest extend
for(int i = 0; i < numMsg; i++)
{
- Message message = consumer.receive(250);
+ Message message = consumer.receive(getReceiveTimeout());
assertNotNull("failed to consume expected message " + i + " from DLQ", message);
assertTrue("message " + i + " was the wrong type", message instanceof TextMessage);
@@ -549,7 +549,7 @@ public class MaxDeliveryCountTest extend
while(!_failed)
{
- Message message = consumer.receive(1000);
+ Message message = consumer.receive(getReceiveTimeout());
_totalNumDeliveries++;
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org