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 33619b7 commit f3199f3Copy full SHA for f3199f3
test/src/com/rabbitmq/examples/MulticastMain.java
@@ -306,14 +306,6 @@ private void logAck(long seqNum) {
306
}
307
308
309
- private void canPublish()
310
- throws InterruptedException
311
- {
312
- if (confirmPool != null) {
313
- confirmPool.acquire();
314
- }
315
316
-
317
public void run() {
318
319
long now;
@@ -324,7 +316,9 @@ public void run() {
324
try {
325
326
while (timeLimit == 0 || now < startTime + timeLimit) {
327
- canPublish();
+ if (confirmPool != null) {
320
+ confirmPool.acquire();
321
+ }
328
322
delay(now);
329
323
publish(createMessage(totalMsgCount));
330
totalMsgCount++;
0 commit comments