diff --git a/sdk/cosmos/azure-cosmos/src/main/java/com/azure/cosmos/implementation/directconnectivity/rntbd/RntbdServiceEndpoint.java b/sdk/cosmos/azure-cosmos/src/main/java/com/azure/cosmos/implementation/directconnectivity/rntbd/RntbdServiceEndpoint.java index a0288d75f1b8..41b07ed1de1f 100644 --- a/sdk/cosmos/azure-cosmos/src/main/java/com/azure/cosmos/implementation/directconnectivity/rntbd/RntbdServiceEndpoint.java +++ b/sdk/cosmos/azure-cosmos/src/main/java/com/azure/cosmos/implementation/directconnectivity/rntbd/RntbdServiceEndpoint.java @@ -213,7 +213,7 @@ private void releaseToPool(final Channel channel) { if (released.isDone()) { ensureSuccessWhenReleasedToPool(channel, released); } else { - this.channelPool.release(channel).addListener(ignored -> ensureSuccessWhenReleasedToPool(channel, released)); + released.addListener(ignored -> ensureSuccessWhenReleasedToPool(channel, released)); } } }