Fix

wzshiming · wzshiming · commit 4534d3837518 · 2025-02-25T13:31:04.000+08:00
diff --git a/queue/controller/message.go b/queue/controller/message.go
@@ -280,7 +280,7 @@ func (mc *MessageController) Schedule(ctx context.Context, logger *slog.Logger)
 						MessageID: item.MessageID,
 						Content:   item.Content,
 						Priority:  item.Priority,
-						Status:    model.StatusPending,
+						Status:    model.StatusCleanup,
 						Data:      item.Data,
 					})
 				}

Original file line number	Diff line number	Diff line change
`@@ -280,7 +280,7 @@ func (mc MessageController) Schedule(ctx context.Context, logger slog.Logger)`
`280`	`280`	`MessageID: item.MessageID,`
`281`	`281`	`Content: item.Content,`
`282`	`282`	`Priority: item.Priority,`
`283`		`- Status: model.StatusPending,`
	`283`	`+ Status: model.StatusCleanup,`
`284`	`284`	`Data: item.Data,`
`285`	`285`	`})`
`286`	`286`	`}`