gitee/cim
1
0
Fork 0
mirror of https://gitee.com/farsunset/cim.git synced 2025-07-19 14:36:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

修改java sdk一处笔误

Browse Source
This commit is contained in:
远方夕阳 2018-10-11 21:30:08 +08:00
parent 7a78be0f3b
commit 473436a271
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
cim_for_netty/cim-java-sdk/src/com/farsunset/cim/sdk/client/CIMConnectorManager.java
View File

@ -129,8 +129,8 @@ class CIMConnectorManager extends SimpleChannelInboundHandler<Object> {
@Override @Override
public void operationComplete(ChannelFuture future) throws Exception { public void operationComplete(ChannelFuture future) throws Exception {
semaphore.release();
future.removeListener(this); future.removeListener(this);
semaphore.acquire();
if(!future.isSuccess() && future.cause() != null) { if(!future.isSuccess() && future.cause() != null) {
handleConnectFailure(future.cause(),remoteAddress); handleConnectFailure(future.cause(),remoteAddress);
} }