nsq连不上继续启动程序

zhangqian

2023-09-19 3b342908721ea54b343adf7d65235f75ebe06b63

nsq连不上继续启动程序

 nsq/nsq.go

@@ -32,28 +32,28 @@
    safe.Go(func() {
        err := Consume(fmt.Sprintf(constvar.NsqTopicScheduleTask, conf.Conf.NsqConf.NodeId), conf.Conf.System.DeviceId)
        if err != nil {
            logx.Fatalf("start nsq consume err: %v", err)
            logx.Errorf("start nsq consume err: %v", err)
        }
    })

    safe.Go(func() {
        err := Consume(fmt.Sprintf(constvar.NsqTopicSendPlcAddress, conf.Conf.NsqConf.NodeId), conf.Conf.System.DeviceId)
        if err != nil {
            logx.Fatalf("start nsq consume err: %v", err)
            logx.Errorf("start nsq consume err: %v", err)
        }
    })

    safe.Go(func() {
        err := Consume(fmt.Sprintf(constvar.NsqTopicProcessParamsResponse, conf.Conf.NsqConf.NodeId), conf.Conf.System.DeviceId)
        if err != nil {
            logx.Fatalf("start nsq consume err: %v", err)
            logx.Errorf("start nsq consume err: %v", err)
        }
    })

    safe.Go(func() {
        err := Consume(fmt.Sprintf(constvar.NsqTopicApsProcessParams, conf.Conf.NsqConf.NodeId), conf.Conf.System.DeviceId)
        if err != nil {
            logx.Fatalf("start nsq consume err: %v", err)
            logx.Errorf("start nsq consume err: %v", err)
        }
    })