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)
|
|
}
|