diff --git a/austin-common/src/main/java/com/java3y/austin/common/domain/TaskInfo.java b/austin-common/src/main/java/com/java3y/austin/common/domain/TaskInfo.java index f8b8e3a..5fa2d1e 100644 --- a/austin-common/src/main/java/com/java3y/austin/common/domain/TaskInfo.java +++ b/austin-common/src/main/java/com/java3y/austin/common/domain/TaskInfo.java @@ -86,5 +86,5 @@ public class TaskInfo implements Serializable, ProcessModel { */ private Integer sendAccount; - private AnchorInfo anchorInfo; + private transient AnchorInfo anchorInfo; } 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 3f68d92..4da9277 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 @@ -31,6 +31,7 @@ public class SendMessageAction implements BusinessProcess { for (String receiver : taskInfo.getReceiver()) { TaskInfo taskClone = ObjectUtil.cloneByStream(taskInfo); taskClone.setReceiver(Sets.newHashSet(receiver)); + taskClone.setAnchorInfo(taskInfo.getAnchorInfo()); handlerHolder.route(taskInfo.getSendChannel()).doHandler(taskClone); } return;