From 0e75fadb580ab7b46ae97b2d85b2243ff57a314d Mon Sep 17 00:00:00 2001
From: Shiming Zhang <wzshiming@hotmail.com>
Date: Tue, 11 Feb 2025 10:06:57 +0800
Subject: [PATCH] Fix watch clean event

---
 queue/controller/message.go | 12 ++++++++++--
 1 file changed, 10 insertions(+), 2 deletions(-)

diff --git a/queue/controller/message.go b/queue/controller/message.go
index 969786d..f36e619 100644
--- a/queue/controller/message.go
+++ b/queue/controller/message.go
@@ -254,7 +254,13 @@ func (mc *MessageController) Schedule(ctx context.Context, logger *slog.Logger)
 					if err != nil {
 						logger.Error("ResetToPending", "error", err)
 					} else {
-						data := MessageResponse{MessageID: item.MessageID, Content: item.Content, Priority: item.Priority, Status: model.StatusPending}
+						data := MessageResponse{
+							MessageID: item.MessageID,
+							Content:   item.Content,
+							Priority:  item.Priority,
+							Status:    model.StatusPending,
+							Data:      item.Data,
+						}
 						mc.appendWatchChannel(item.MessageID, data)
 						mc.appendWatchListChannels(data)
 					}
@@ -273,7 +279,9 @@ func (mc *MessageController) Schedule(ctx context.Context, logger *slog.Logger)
 					mc.appendWatchListChannels(MessageResponse{
 						MessageID: item.MessageID,
 						Content:   item.Content,
-						Status:    model.StatusCleanup,
+						Priority:  item.Priority,
+						Status:    model.StatusPending,
+						Data:      item.Data,
 					})
 				}
 			}