We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 0677b2d commit 6bfb7f6Copy full SHA for 6bfb7f6
test/src/com/rabbitmq/client/test/functional/PerQueueTTL.java
@@ -157,10 +157,10 @@ public void testTransactionalPublishWithGet() throws Exception {
157
* Test expiry of requeued messages
158
*/
159
public void testExpiryWithRequeue() throws Exception {
160
- declareAndBindQueue(100);
+ declareAndBindQueue(200);
161
162
publish(MSG[0]);
163
- Thread.sleep(50);
+ Thread.sleep(100);
164
publish(MSG[1]);
165
publish(MSG[2]);
166
@@ -170,7 +170,7 @@ public void testExpiryWithRequeue() throws Exception {
170
closeChannel();
171
openChannel();
172
173
- Thread.sleep(60);
+ Thread.sleep(150);
174
expectBodyAndRemainingMessages(MSG[1], 1);
175
expectBodyAndRemainingMessages(MSG[2], 0);
176
}
0 commit comments