diff --git a/common.go b/common.go index 0d0bb02..36b013f 100644 --- a/common.go +++ b/common.go @@ -152,11 +152,16 @@ const CHANNEL_ORDER_ASKPAY_QUEUE = "channel_order_askpay_queue" func rpc_server_conn(url ...string) (*RabbitmqServiceClient, error) { - var wx_rpc_url string = "127.0.0.1:7955" + var rpc_url string if len(url) > 0 && url[0] != "" { - wx_rpc_url = url[0] + rpc_url = url[0] + } else if conf.RABBITMQ_RPC_URL != "" { + rpc_url = conf.RABBITMQ_RPC_URL + } else { + rpc_url = "127.0.0.1:" + conf.RABBITMQ_RPC_PORT } - conn, _, err := DialRabbitmqService("tcp", wx_rpc_url) + + conn, _, err := DialRabbitmqService("tcp", rpc_url) if err != nil { return nil, err }