race-condition during RedisConnection.forceFastReconnectAsync invocation

pull/1124/head
Nikita 7 years ago
parent f070392afa
commit 99d515c19b

@ -247,9 +247,10 @@ public class RedisConnection implements RedisCommands {
}
public RFuture<Void> forceFastReconnectAsync() {
fastReconnect = new RedissonPromise<Void>();
RedissonPromise<Void> promise = new RedissonPromise<Void>();
fastReconnect = promise;
channel.close();
return fastReconnect;
return promise;
}
/**

Loading…
Cancel
Save