mirror of
https://github.com/apache/activemq-artemis.git
synced 2025-02-07 02:29:08 +00:00
This closes #247
This commit is contained in:
commit
c5dc42657f
@ -49,7 +49,7 @@ public class JMSIndividualAckTest extends BasicOpenWireTest {
|
|||||||
|
|
||||||
// Consume the message...
|
// Consume the message...
|
||||||
MessageConsumer consumer = session.createConsumer(queue);
|
MessageConsumer consumer = session.createConsumer(queue);
|
||||||
Message msg = consumer.receive(1000);
|
Message msg = consumer.receive(5000);
|
||||||
assertNotNull(msg);
|
assertNotNull(msg);
|
||||||
msg.acknowledge();
|
msg.acknowledge();
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user