Reverting change that was performed on a merge commit at 1ba1de4248

During my merging of #2906, I ammended a change by accident on the Close commit,
This is to revert the change and reapply it on a :
This commit is contained in:
Clebert Suconic 2019-12-03 10:08:46 -05:00
parent 77c2451ea4
commit 3db5ffd40c
1 changed files with 1 additions and 1 deletions

View File

@ -104,7 +104,7 @@ public class AMQPMessageRedistributionTest extends ClusterTestBase {
TextMessage msg = (TextMessage) consumer.receive(5000);
assertNotNull(msg);
}
Message msg = consumer.receiveNoWait();
Message msg = consumer.receive(2000);
assertNull(msg);
connection.close();
}