We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 06b9056 commit f7ecc5cCopy full SHA for f7ecc5c
driver-core/src/main/java/com/datastax/driver/core/Connection.java
@@ -754,9 +754,11 @@ public ConnectionCloseFuture force() {
754
ChannelFuture future = channel.close();
755
future.addListener(new ChannelFutureListener() {
756
public void operationComplete(ChannelFuture future) {
757
- if (future.getCause() != null)
+ factory.allChannels.remove(channel);
758
+ if (future.getCause() != null) {
759
+ logger.warn("Error closing channel", future.getCause());
760
ConnectionCloseFuture.this.setException(future.getCause());
- else
761
+ } else
762
ConnectionCloseFuture.this.set(null);
763
}
764
});
0 commit comments