Skip to content

Commit f5d835a

Browse files
Remove unused method
1 parent d177c24 commit f5d835a

File tree

1 file changed

+0
-11
lines changed

1 file changed

+0
-11
lines changed

test/src/com/rabbitmq/client/test/functional/ConnectionRecovery.java

Lines changed: 0 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -363,17 +363,6 @@ private AMQP.Queue.DeclareOk declareClientNamedQueue(Channel ch, String q) throw
363363
return ch.queueDeclare(q, true, false, false, null);
364364
}
365365

366-
private void waitForShutdown() throws InterruptedException {
367-
final CountDownLatch latch = new CountDownLatch(1);
368-
connection.addShutdownListener(new ShutdownListener() {
369-
@Override
370-
public void shutdownCompleted(ShutdownSignalException cause) {
371-
latch.countDown();
372-
}
373-
});
374-
wait(latch, false);
375-
}
376-
377366
private CountDownLatch prepareForShutdown(AutorecoveringConnection conn) throws InterruptedException {
378367
final CountDownLatch latch = new CountDownLatch(1);
379368
conn.addShutdownListener(new ShutdownListener() {

0 commit comments

Comments
 (0)