rabbitmqrpc/send_delay_test.go

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