nsq消费者启动失败直接退出程序

zhangqian

2023-09-12 d1c88cc0fea23c36d08c2d2015c4379d020de255

nsq消费者启动失败直接退出程序

 nsq/nsq.go

@@ -30,19 +30,31 @@
    })

    safe.Go(func() {
        _ = Consume(fmt.Sprintf(constvar.NsqTopicScheduleTask, conf.Conf.NsqConf.NodeId), conf.Conf.System.DeviceId)
        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)
        }
    })

    safe.Go(func() {
        _ = Consume(fmt.Sprintf(constvar.NsqTopicSendPlcAddress, conf.Conf.NsqConf.NodeId), conf.Conf.System.DeviceId)
        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)
        }
    })

    safe.Go(func() {
        _ = Consume(fmt.Sprintf(constvar.NsqTopicProcessParamsResponse, conf.Conf.NsqConf.NodeId), conf.Conf.System.DeviceId)
        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)
        }
    })

    safe.Go(func() {
        _ = Consume(fmt.Sprintf(constvar.NsqTopicApsProcessParams, conf.Conf.NsqConf.NodeId), conf.Conf.System.DeviceId)
        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)
        }
    })

    return nil