消息持久化

rabbitmq.go

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