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 23d0715 commit cb83224Copy full SHA for cb83224
test/src/com/rabbitmq/client/test/functional/TTLHandling.java
@@ -121,10 +121,10 @@ public void testTransactionalPublishWithGet() throws Exception {
121
}
122
123
public void testExpiryWithRequeue() throws Exception {
124
- declareAndBindQueue(100);
+ declareAndBindQueue(200);
125
126
publish(MSG[0]);
127
- Thread.sleep(50);
+ Thread.sleep(100);
128
publish(MSG[1]);
129
publish(MSG[2]);
130
@@ -134,7 +134,7 @@ public void testExpiryWithRequeue() throws Exception {
134
closeChannel();
135
openChannel();
136
137
- Thread.sleep(60);
+ Thread.sleep(150);
138
expectBodyAndRemainingMessages(MSG[1], 1);
139
expectBodyAndRemainingMessages(MSG[2], 0);
140
0 commit comments