Merge pull request #9 from frain-dev/enhancement/msgpack-encoding

remove msgpack encoding

Author: ogbanugot

handler.go

@@ -137,12 +137,6 @@ func (h *reflectFunc) fnArgs(msg *Message) ([]reflect.Value, error) {
 
 	for i := 0; i < len(in); i++ {
 		arg := reflect.New(h.ft.In(inStart + i)).Elem()
-		err = dec.DecodeValue(arg)
-		if err != nil {
-			err = fmt.Errorf(
-				"disq: decoding arg=%d failed (data=%.100x): %s", i, b, err)
-			return nil, err
-		}
 		in[i] = arg
 	}
 

message.go

@@ -13,16 +13,18 @@ type Message struct {
 
 	ID string
 
-	TaskName string
+	Name string
 
-	// Delay specifies the duration the worker must wait
+	// Delay specifies the duration the queue must wait
 	// before executing the message.
 	Delay time.Duration
 
-	// Args passed to the handler.
-	Args    []interface{}
+	Args []interface{}
+
 	ArgsBin []byte
-	// The number of times the message has been reserved or released.
+
+	TaskName string
+
 	RetryCount int
 
 	//Execution time need for localstorage delays