diff --git a/austin-handler/src/main/java/com/java3y/austin/handler/action/SendMessageAction.java b/austin-handler/src/main/java/com/java3y/austin/handler/action/SendMessageAction.java index d3c57b5..2b1a6ab 100644 --- a/austin-handler/src/main/java/com/java3y/austin/handler/action/SendMessageAction.java +++ b/austin-handler/src/main/java/com/java3y/austin/handler/action/SendMessageAction.java @@ -10,7 +10,6 @@ import com.java3y.austin.handler.handler.HandlerHolder; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; - /** * 发送消息,路由到对应的渠道下发消息 * @@ -29,8 +28,8 @@ public class SendMessageAction implements BusinessProcess { if (ChannelType.MINI_PROGRAM.getCode().equals(taskInfo.getSendChannel()) || ChannelType.OFFICIAL_ACCOUNT.getCode().equals(taskInfo.getSendChannel()) || ChannelType.ALIPAY_MINI_PROGRAM.getCode().equals(taskInfo.getSendChannel())) { + TaskInfo taskClone = ObjectUtil.cloneByStream(taskInfo); for (String receiver : taskInfo.getReceiver()) { - TaskInfo taskClone = ObjectUtil.cloneByStream(taskInfo); taskClone.setReceiver(Sets.newHashSet(receiver)); handlerHolder.route(taskInfo.getSendChannel()).doHandler(taskClone); }