diff --git a/src/org/redkale/net/http/WebSocketNode.java b/src/org/redkale/net/http/WebSocketNode.java index b390da0ba..c0b87e4c3 100644 --- a/src/org/redkale/net/http/WebSocketNode.java +++ b/src/org/redkale/net/http/WebSocketNode.java @@ -106,7 +106,7 @@ public abstract class WebSocketNode { * * @return 地址列表 */ - public CompletableFuture> getSncpNodeAddresses(final Serializable groupid) { + public CompletableFuture> getRpcNodeAddresses(final Serializable groupid) { if (this.sncpNodeAddresses != null) return this.sncpNodeAddresses.getCollectionAsync(groupid); List rs = new ArrayList<>(); rs.add(this.localSncpAddress); @@ -122,8 +122,8 @@ public abstract class WebSocketNode { * * @return 地址集合 */ - public CompletableFuture>> getSncpNodeWebSocketAddresses(final Serializable groupid) { - CompletableFuture> sncpFuture = getSncpNodeAddresses(groupid); + public CompletableFuture>> getRpcNodeWebSocketAddresses(final Serializable groupid) { + CompletableFuture> sncpFuture = getRpcNodeAddresses(groupid); return sncpFuture.thenCompose((Collection addrs) -> { if (finest) logger.finest("websocket found groupid:" + groupid + " on " + addrs); if (addrs == null || addrs.isEmpty()) return CompletableFuture.completedFuture(new HashMap<>());