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.
2 parents 22afbf4 + 6bfb7f6 commit 5812569Copy full SHA for 5812569
test/src/com/rabbitmq/client/test/functional/PerQueueTTL.java
@@ -157,10 +157,10 @@ public void testTransactionalPublishWithGet() throws Exception {
157
* Test expiry of re-queued 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