Test fixed

pull/665/head
Nikita 9 years ago
parent ef3a7200be
commit f6e547b03c

@ -79,6 +79,10 @@ public class ConnectionWatchdog extends ChannelInboundHandlerAdapter {
private void reconnect(final RedisConnection connection, final int attempts){
int timeout = 2 << attempts;
if (bootstrap.group().isShuttingDown()) {
return;
}
timer.newTimeout(new TimerTask() {
@Override
public void run(Timeout timeout) throws Exception {

@ -46,7 +46,7 @@ public class WeightedRoundRobinBalancerTest {
slave.stop();
RedissonClient clientCopy = client;
await().atMost(5, TimeUnit.SECONDS).until(() -> assertThat(clientCopy.getBucket("key").get()).isNull());
assertThat(clientCopy.getBucket("key").get()).isNull();
} finally {
if (master != null) {
master.stop();

Loading…
Cancel
Save