rabbitmq/send_test.go

package rabbitmq

import (
	"testing"
)

func Test_Send(t *testing.T) {
	err := Connect("127.0.0.1", "5672", "tetele", "fly123456@", "ttl")
	t.Log(err)

	err = Channel()
	t.Log(err)

	body := []byte("order is expire")
	// err = Send("direct", "ex_order_delay", "order_expire", body)
	err = SendDelay("direct", "ex_order_delay", "order_expire", body, 5000)

	t.Log(err)
}