chore(queue): don't allocate new message (#102)

Author: appleboy

Diff for: job/job.go

@@ -47,6 +47,15 @@ func (m *Message) Encode() []byte {
 	return b
 }
 
+// Rest for reset default value
+func (m *Message) Rest() {
+	m.Task = nil
+	m.Payload = nil
+	m.RetryCount = 0
+	m.Timeout = 0
+	m.RetryDelay = 0
+}
+
 func NewMessage(m core.QueuedMessage, opts ...AllowOption) *Message {
 	o := NewOptions(opts...)
 

Diff for: queue.go

@@ -120,10 +120,11 @@ func (q *Queue) Queue(m core.QueuedMessage, opts ...job.AllowOption) error {
 	}
 
 	message := job.NewMessage(m, opts...)
+	payload := message.Encode()
+	message.Rest()
+	message.Payload = payload
 
-	if err := q.worker.Queue(&job.Message{
-		Payload: message.Encode(),
-	}); err != nil {
+	if err := q.worker.Queue(message); err != nil {
 		return err
 	}