mirror of https://github.com/apache/activemq.git
Fix for intermittent failures, see https://issues.apache.org/jira/browse/AMQ-5053
This commit is contained in:
parent
a059bf4a90
commit
4350ded2c5
|
@ -107,7 +107,7 @@ public class BrokerRedeliveryTest extends org.apache.activemq.TestSupport {
|
||||||
consumerConnection.start();
|
consumerConnection.start();
|
||||||
Session consumerSession = consumerConnection.createSession(false, Session.CLIENT_ACKNOWLEDGE);
|
Session consumerSession = consumerConnection.createSession(false, Session.CLIENT_ACKNOWLEDGE);
|
||||||
MessageConsumer consumer = consumerSession.createConsumer(destination);
|
MessageConsumer consumer = consumerSession.createConsumer(destination);
|
||||||
sendMessage(1000);
|
sendMessage(1500);
|
||||||
Message message = consumer.receive(1000);
|
Message message = consumer.receive(1000);
|
||||||
assertNotNull("got message", message);
|
assertNotNull("got message", message);
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue