|
21 | 21 | import java.util.concurrent.atomic.AtomicInteger;
|
22 | 22 | import java.util.concurrent.atomic.AtomicReference;
|
23 | 23 |
|
| 24 | +@SuppressWarnings("ThrowFromFinallyBlock") |
24 | 25 | public class ConnectionRecovery extends BrokerTestCase {
|
25 |
| - public static final long RECOVERY_INTERVAL = 2000; |
| 26 | + private static final long RECOVERY_INTERVAL = 2000; |
26 | 27 |
|
27 | 28 | public void testConnectionRecovery() throws IOException, InterruptedException {
|
28 | 29 | assertTrue(connection.isOpen());
|
@@ -211,7 +212,7 @@ public void testClientNamedQueueRecoveryWithNoWait() throws IOException, Interru
|
211 | 212 | testClientNamedQueueRecoveryWith("java-client.test.recovery.q1-nowait", true);
|
212 | 213 | }
|
213 | 214 |
|
214 |
| - protected void testClientNamedQueueRecoveryWith(String q, boolean noWait) throws IOException, InterruptedException, TimeoutException { |
| 215 | + private void testClientNamedQueueRecoveryWith(String q, boolean noWait) throws IOException, InterruptedException, TimeoutException { |
215 | 216 | Channel ch = connection.createChannel();
|
216 | 217 | if(noWait) {
|
217 | 218 | declareClientNamedQueueNoWait(ch, q);
|
@@ -759,11 +760,11 @@ private void waitForConfirms(Channel ch) throws InterruptedException, TimeoutExc
|
759 | 760 | ch.waitForConfirms(30 * 60 * 1000);
|
760 | 761 | }
|
761 | 762 |
|
762 |
| - protected void assertRecordedQueues(Connection conn, int size) { |
| 763 | + private void assertRecordedQueues(Connection conn, int size) { |
763 | 764 | assertEquals(size, ((AutorecoveringConnection)conn).getRecordedQueues().size());
|
764 | 765 | }
|
765 | 766 |
|
766 |
| - protected void assertRecordedExchanges(Connection conn, int size) { |
| 767 | + private void assertRecordedExchanges(Connection conn, int size) { |
767 | 768 | assertEquals(size, ((AutorecoveringConnection)conn).getRecordedExchanges().size());
|
768 | 769 | }
|
769 | 770 | }
|
0 commit comments