diff --git a/client_test.go b/client_test.go index 55f3903..cc2952e 100644 --- a/client_test.go +++ b/client_test.go @@ -1,7 +1,6 @@ package rabbitmqrpc import ( - "encoding/json" "testing" ) @@ -18,9 +17,8 @@ func Test_Send(t *testing.T) { "order_sn": "cccc", }, } - data, _ := json.Marshal(msg) - ret, err := Send(exchange, key, string(data)) + ret, err := Send(exchange, key, msg) t.Log(ret) t.Log(err) diff --git a/send_delay_test.go b/send_delay_test.go new file mode 100644 index 0000000..01f6cc2 --- /dev/null +++ b/send_delay_test.go @@ -0,0 +1,25 @@ +package rabbitmqrpc + +import ( + "testing" +) + +func Test_SendDelay(t *testing.T) { + + exchange := "ex_order_delay" + key := "order_expire" + + msg := map[string]interface{}{ + "site_id": "100002", + "dbname": "testing", + "data": map[string]string{ + "order_id": "111", + "order_sn": "cccc", + }, + } + + ret, err := SendDelay(exchange, key, msg, 20) + + t.Log(ret) + t.Log(err) +}