ARTEMIS-2560 Re-applying fix on a test properly
This commit is contained in:
parent
3db5ffd40c
commit
54e3f167bb
|
@ -104,7 +104,7 @@ public class AMQPMessageRedistributionTest extends ClusterTestBase {
|
|||
TextMessage msg = (TextMessage) consumer.receive(5000);
|
||||
assertNotNull(msg);
|
||||
}
|
||||
Message msg = consumer.receive(2000);
|
||||
Message msg = consumer.receiveNoWait();
|
||||
assertNull(msg);
|
||||
connection.close();
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue