diff --git a/rabbitmq.go b/rabbitmq.go index 302b483..474e440 100644 --- a/rabbitmq.go +++ b/rabbitmq.go @@ -106,9 +106,11 @@ func (r *rabbitmq) Publish(exchangeName, msg string, delay ...int64) error { false, //强制为 false, //立即 amqp.Publishing{ - ContentType: "text/plain", - Body: []byte(msg), - Headers: header, + ContentType: "text/plain", + Body: []byte(msg), + DeliveryMode: amqp.Persistent, + Timestamp: time.Now(), + Headers: header, }) }