feat: expose EnqueueTime

xiaojiaoyu100 · Jan 4, 2019 · 485be35 · 485be35
1 parent 183c650
commit 485be35
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git 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
@@ -8,6 +8,7 @@ import (
 type M struct {
 	MessageBody    string
 	MessageBodyMD5 string
+	EnqueueTime    int64
 }
 
 // Handler 消息处理函数模板