@Test public void testResetDelayMs() throws Exception { long now = System.currentTimeMillis(); timeProvider.setTime(now); int delay = 0; while (delay < maxDelay) { delay = delayManager.getReconnectDelayMs(address); } now += resetTime; timeProvider.setTime(now); assertEquals(initialDelay, delayManager.getReconnectDelayMs(address)); assertEquals(initialDelay * 2, delayManager.getReconnectDelayMs(address)); }
public int getReconnectDelayMs(InetSocketAddress socketAddress) { return getReconnectDelayMs(socketAddress.getAddress()); }
ReconnectDelayManager { public int getReconnectDelayMs(InetSocketAddress socketAddress) { return getReconnectDelayMs(socketAddress.getAddress()); } }
ReconnectDelayManager { public int getReconnectDelayMs(InetSocketAddress socketAddress) { return getReconnectDelayMs(socketAddress.getAddress()); } ReconnectDelayManager();  ReconnectDelayManager(final int initialReconnectDelayMs,
                                 final int maxReconnectDelayMs,
                                 final int reconnectDelayResetMs,
                                 final TimeProvider timeProvider); }
ReconnectDelayManager { public int getReconnectDelayMs(InetSocketAddress socketAddress) { return getReconnectDelayMs(socketAddress.getAddress()); } ReconnectDelayManager();  ReconnectDelayManager(final int initialReconnectDelayMs,
                                 final int maxReconnectDelayMs,
                                 final int reconnectDelayResetMs,
                                 final TimeProvider timeProvider); int getReconnectDelayMs(InetSocketAddress socketAddress); int getReconnectDelayMs(InetAddress address); }
ReconnectDelayManager { public int getReconnectDelayMs(InetSocketAddress socketAddress) { return getReconnectDelayMs(socketAddress.getAddress()); } ReconnectDelayManager();  ReconnectDelayManager(final int initialReconnectDelayMs,
                                 final int maxReconnectDelayMs,
                                 final int reconnectDelayResetMs,
                                 final TimeProvider timeProvider); int getReconnectDelayMs(InetSocketAddress socketAddress); int getReconnectDelayMs(InetAddress address); static final int DEFAULT_RECONNECT_DELAY_INITIAL_MS; static final int DEFAULT_RECONNECT_MAX_DELAY_MS; static final int DEFAULT_RECONNECT_DELAY_RESET_TIME_MS; static TimeProvider DEFAULT_TIMEPROVIDER; }