diff --git a/irpc-framework-core/src/main/java/org/idea/irpc/framework/core/filter/client/GroupFilterImpl.java b/irpc-framework-core/src/main/java/org/idea/irpc/framework/core/filter/client/GroupFilterImpl.java index d0966de30b9ec40d11394377b6205fd29321b885..e161ba479125814e4b26359167fc21ea3b8619ce 100644 --- a/irpc-framework-core/src/main/java/org/idea/irpc/framework/core/filter/client/GroupFilterImpl.java +++ b/irpc-framework-core/src/main/java/org/idea/irpc/framework/core/filter/client/GroupFilterImpl.java @@ -19,6 +19,9 @@ public class GroupFilterImpl implements IClientFilter { @Override public void doFilter(List src, RpcInvocation rpcInvocation) { String group = String.valueOf(rpcInvocation.getAttachments().get("group")); + if (CommonUtils.isEmpty(group)) { + return; + } for (ChannelFutureWrapper channelFutureWrapper : src) { if (!channelFutureWrapper.getGroup().equals(group)) { src.remove(channelFutureWrapper);