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