diff --git a/cim_for_netty/cim-java-sdk/src/com/farsunset/cim/sdk/client/CIMConnectorManager.java b/cim_for_netty/cim-java-sdk/src/com/farsunset/cim/sdk/client/CIMConnectorManager.java index bfc0234..f0038a7 100644 --- a/cim_for_netty/cim-java-sdk/src/com/farsunset/cim/sdk/client/CIMConnectorManager.java +++ b/cim_for_netty/cim-java-sdk/src/com/farsunset/cim/sdk/client/CIMConnectorManager.java @@ -129,8 +129,8 @@ class CIMConnectorManager extends SimpleChannelInboundHandler { @Override public void operationComplete(ChannelFuture future) throws Exception { + semaphore.release(); future.removeListener(this); - semaphore.acquire(); if(!future.isSuccess() && future.cause() != null) { handleConnectFailure(future.cause(),remoteAddress); }