diff --git a/src/org/redkale/net/http/WebSocketNode.java b/src/org/redkale/net/http/WebSocketNode.java index 06108e5a6..21829ac1f 100644 --- a/src/org/redkale/net/http/WebSocketNode.java +++ b/src/org/redkale/net/http/WebSocketNode.java @@ -96,9 +96,9 @@ public abstract class WebSocketNode { protected abstract CompletableFuture disconnect(Serializable userid, InetSocketAddress addr); - protected abstract CompletableFuture changeUserid(Serializable fromuserid, Serializable touserid, InetSocketAddress addr); + protected abstract CompletableFuture changeUserid(Serializable fromuserid, Serializable touserid, @RpcTargetAddress InetSocketAddress addr); - protected abstract CompletableFuture forceCloseWebSocket(Serializable userid, InetSocketAddress addr); + protected abstract CompletableFuture forceCloseWebSocket(Serializable userid, @RpcTargetAddress InetSocketAddress addr); //-------------------------------------------------------------------------------- final CompletableFuture connect(final Serializable userid) {