Merge branch '0.3.x/EFA-2910' into '0.3.x/release'

0.3.x/EFA-2910

See merge request effectivex/go-kit!29

transport/transport.go

@@ -2,6 +2,7 @@ package transport
 
 import (
 	"context"
+	"encoding/json"
 )
 
 type RpcClient interface {
@@ -25,8 +26,8 @@ type MessageBody []byte
 type Handler func(data MessageBody, ackFunc func(), nackFunc func(requeue bool))
 
 type RpcMessage struct {
-	Method string `json:"method"`
-	Params []byte `json:"params"`
+	Method string          `json:"method"`
+	Params json.RawMessage `json:"params"`
 }
 
 type ResponseData interface{}