@ -460,6 +460,7 @@ public class CommandAsyncService implements CommandAsyncExecutor {
}
if (!details.getConnectionFuture().isSuccess()) {
connectionManager.getShutdownLatch().release();
details.setException(convertException(details.getConnectionFuture()));
return;
@ -333,6 +333,7 @@ public class CommandBatchService extends CommandReactiveService {
if (!connFuture.isSuccess()) {
details.setException(convertException(connFuture));