From 41aadf33f311df8b7da14a8d6f11f2225920d88d Mon Sep 17 00:00:00 2001 From: Redkale <22250530@qq.com> Date: Sun, 26 Mar 2017 14:28:06 +0800 Subject: [PATCH] --- src/org/redkale/net/sncp/SncpClient.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/org/redkale/net/sncp/SncpClient.java b/src/org/redkale/net/sncp/SncpClient.java index 3a917c3c1..a08d13fb8 100644 --- a/src/org/redkale/net/sncp/SncpClient.java +++ b/src/org/redkale/net/sncp/SncpClient.java @@ -248,6 +248,7 @@ public final class SncpClient { } public void remoteSameGroup(final BsonConvert bsonConvert, final JsonConvert jsonConvert, Transport transport, final int index, final Object... params) { + if (transport == null) return; final SncpAction action = actions[index]; if (action.handlerFuncParamIndex >= 0) params[action.handlerFuncParamIndex] = null; //不能让远程调用handler,因为之前本地方法已经调用过了 for (InetSocketAddress addr : transport.getRemoteAddresses()) { @@ -256,6 +257,7 @@ public final class SncpClient { } public void asyncRemoteSameGroup(final BsonConvert bsonConvert, final JsonConvert jsonConvert, Transport transport, final int index, final Object... params) { + if (transport == null) return; if (executor != null) { executor.accept(() -> { remoteSameGroup(bsonConvert, jsonConvert, transport, index, params);