diff --git a/consumer.go b/consumer.go
index 1c98692..59b245b 100644
--- a/consumer.go
+++ b/consumer.go
@@ -302,6 +302,7 @@ func (c *Consumer) OnReceive(queue *Queue, receiveMsg *ReceiveMessage) {
 		m := new(M)
 		m.MessageBody = receiveMsg.MessageBody
 		m.MessageBodyMD5 = receiveMsg.MessageBodyMD5
+		m.EnqueueTime = receiveMsg.EnqueueTime
 		errChan <- queue.OnReceive(m)
 	}()
 
diff --git a/queue.go b/queue.go
index b8d38f6..872bafd 100644
--- a/queue.go
+++ b/queue.go
@@ -8,6 +8,7 @@ import (
 type M struct {
 	MessageBody    string
 	MessageBodyMD5 string
+	EnqueueTime    int64
 }
 
 // Handler 消息处理函数模板