diff --git a/im-center-server/src/main/java/cn/axzo/im/controller/MessageController.java b/im-center-server/src/main/java/cn/axzo/im/controller/MessageController.java
index a3577c3..2115fe8 100644
--- a/im-center-server/src/main/java/cn/axzo/im/controller/MessageController.java
+++ b/im-center-server/src/main/java/cn/axzo/im/controller/MessageController.java
@@ -25,6 +25,7 @@ import cn.axzo.im.service.RobotMsgTemplateService;
 import cn.axzo.pokonyan.exception.Aassert;
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
+import com.google.common.collect.Sets;
 import io.github.resilience4j.ratelimiter.RequestNotPermitted;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -113,7 +114,7 @@ public class MessageController implements MessageApi {
         messageTaskService.createMessageHistory(messageTask);
         List<MessageHistoryService.MessageHistoryDTO> messageHistories = messageHistoryService.list(MessageHistoryService.ListMessageHistoryParam.builder()
                 .imMessageTaskId(messageTask.getId())
-                .status(MessageHistory.Status.PENDING.name())
+                .statues(Sets.newHashSet(MessageHistory.Status.PENDING.name()))
                 .build());
         if (!CollectionUtils.isEmpty(messageHistories)) {
             messageHistoryService.sendMessage(messageHistories);
diff --git a/im-center-server/src/main/java/cn/axzo/im/job/SendMessageJob.java b/im-center-server/src/main/java/cn/axzo/im/job/SendMessageJob.java
index 340c83d..79f76fd 100644
--- a/im-center-server/src/main/java/cn/axzo/im/job/SendMessageJob.java
+++ b/im-center-server/src/main/java/cn/axzo/im/job/SendMessageJob.java
@@ -4,6 +4,7 @@ import cn.axzo.im.entity.MessageHistory;
 import cn.axzo.im.service.MessageHistoryService;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.google.common.collect.Sets;
 import com.xxl.job.core.biz.model.ReturnT;
 import com.xxl.job.core.handler.IJobHandler;
 import com.xxl.job.core.handler.annotation.XxlJob;
@@ -45,7 +46,7 @@ public class SendMessageJob extends IJobHandler {
         while (true) {
             MessageHistoryService.PageMessageHistoryParam req = MessageHistoryService.PageMessageHistoryParam.builder()
                     .ids(sendMessageParam.getIds())
-                    .status(MessageHistory.Status.PENDING.name())
+                    .statues(Sets.newHashSet(MessageHistory.Status.PENDING.name()))
                     .pageNumber(pageNumber++)
                     .pageSize(DEFAULT_PAGE_SIZE)
                     .build();