From bb73657c33f39d4b956bc431ac9cf96110640864 Mon Sep 17 00:00:00 2001
From: kanade <kanade@kumo.work>
Date: Fri, 18 Nov 2022 16:07:51 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B6=88=E6=81=AF=E6=8C=81=E4=B9=85=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 rabbitmq.go | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

diff --git a/rabbitmq.go b/rabbitmq.go
index c90b9e0..302b483 100644
--- a/rabbitmq.go
+++ b/rabbitmq.go
@@ -133,9 +133,11 @@ func (r *rabbitmq) PublishWithContext(ctx context.Context, exchangeName, key, ms
 		false,        //强制为
 		false,        //立即
 		amqp.Publishing{
-			ContentType: "text/plain",
-			Body:        []byte(msg),
-			Headers:     header,
+			ContentType:  "text/plain",
+			DeliveryMode: amqp.Persistent,
+			Timestamp:    time.Now(),
+			Body:         []byte(msg),
+			Headers:      header,
 		})
 }