|
@ -11,7 +11,7 @@ import ( |
|
|
"github.com/golang/protobuf/proto" |
|
|
"github.com/golang/protobuf/proto" |
|
|
) |
|
|
) |
|
|
|
|
|
|
|
|
func SendDelay(exchange, key string, data interface{}, delay int, url ...string) (*MsgSend, error) { |
|
|
|
|
|
|
|
|
func SendDelay(exchange, key string, data interface{}, delay int64, url ...string) (*MsgSend, error) { |
|
|
|
|
|
|
|
|
conn, err := rpc_server_conn(url...) |
|
|
conn, err := rpc_server_conn(url...) |
|
|
if err != nil { |
|
|
if err != nil { |
|
|