消息持久化

rabbitmq.go

@@ -108,6 +108,8 @@ func (r *rabbitmq) Publish(exchangeName, msg string, delay ...int64) error {
 		amqp.Publishing{
 			ContentType:  "text/plain",
 			Body:         []byte(msg),
+			DeliveryMode: amqp.Persistent,
+			Timestamp:    time.Now(),
 			Headers:      header,
 		})
 }