diff --git a/config.yaml b/config.yaml index f3b5eca..6c8627c 100644 --- a/config.yaml +++ b/config.yaml @@ -62,7 +62,7 @@ wechat: # [rabbitMq] amqp: - host: 127.0.0.1 + host: 42.193.16.243 port: 5672 user: gdxz_2022rabbitmq password: qwr2p&¥e@3.2p diff --git a/core/rabbitMq.go b/core/rabbitMq.go index 8fac9af..72a35dd 100644 --- a/core/rabbitMq.go +++ b/core/rabbitMq.go @@ -39,7 +39,6 @@ func StartRabbitMqConsume() { RoutingKey: "CouponExpired", Handler: consumer.CouponExpire, } - go startConsumer(s) // 取消未支付订单 @@ -49,7 +48,6 @@ func StartRabbitMqConsume() { RoutingKey: "CancelUnPayOrder", Handler: consumer.CancelUnPayOrder, } - go startConsumer(s) }