更换手机号时 会员关系 解除
This commit is contained in:
@@ -113,6 +113,10 @@ public class PushToClientChannelHandlerAdapter extends NettyChannelHandlerAdapte
|
||||
this.shopId=shopId;
|
||||
if (webSocketMap.containsKey(shopId)) {
|
||||
ConcurrentHashMap<String, ChannelHandlerContext> clientSocketMap = webSocketMap.get(shopId);
|
||||
ChannelHandlerContext channelHandlerContext = clientSocketMap.get(clientId);
|
||||
if (channelHandlerContext != null) {
|
||||
channelHandlerContext.close();
|
||||
}
|
||||
clientSocketMap.put(clientId, ctx);
|
||||
} else {
|
||||
ConcurrentHashMap<String, ChannelHandlerContext> clientSocketMap = new ConcurrentHashMap<>();
|
||||
|
||||
Reference in New Issue
Block a user