From 5326293550bccb778d51d703b4a561f76b377ef0 Mon Sep 17 00:00:00 2001 From: guzeng Date: Tue, 31 Aug 2021 09:37:07 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E8=BF=9C=E7=A8=8B=E8=B0=83?= =?UTF-8?q?=E7=94=A8=E5=9C=B0=E5=9D=80=EF=BC=8C=E5=A2=9E=E5=8A=A0=E9=85=8D?= =?UTF-8?q?=E7=BD=AE=E5=88=A4=E6=96=AD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- common.go | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 deletions(-) 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 }