Fixed bug with hanging when writing to previous CQE replica right after switch, closes
@@ -133,7 +133,7 @@ public class HostConnector<T extends ClusteredNetworkContext<T>, C extends Clust
synchronized void reconnect() {
close();
- if (!eventLoop.isClosed())
+ if (!eventLoop.isClosing())
connect();
}
}
\ No newline at end of file
