Unverified Commit 6b3024ce authored by bwcx_jzy's avatar bwcx_jzy
Browse files

fix node update

No related merge requests found
Showing with 11 additions and 2 deletions
+11 -2
......@@ -112,6 +112,16 @@ public class NodeClient extends WebSocketClient {
super.send(text);
}
@Override
public void close() {
try {
super.close();
} catch (Exception e) {
DefaultSystemLog.getLog().error("关闭异常", e);
}
}
@Override
public void send(ByteBuffer bytes) {
super.send(bytes);
......
......@@ -111,8 +111,7 @@ public class NodeUpdateHandler extends BaseProxyHandler {
NodeClient nodeClient = clientMap.get(model.getId());
if (nodeClient != null) {
//
nodeClient.getVersion();
continue;
nodeClient.close();
}
Map<String, Object> attributes = session.getAttributes();
String url = NodeForward.getSocketUrl(model, NodeUrl.NodeUpdate, (UserModel) attributes.get("userInfo"));
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment