接收bashboard消息并存储

zhangqian

2023-12-04 6445381c4c40f64fe8c600bbd2d5508b2880822a

接收bashboard消息并存储

 nsq/consumer.go

@@ -26,7 +26,7 @@
    case fmt.Sprintf(constvar.NsqTopicPullDataResponse, conf.Conf.NsqConf.NodeId):
        handler = &PullDataResponse{Topic: topic}
    case fmt.Sprintf(constvar.NsqTopicSendDashboardData, conf.Conf.NsqConf.NodeId):
        handler = &PullDataResponse{Topic: topic}
        handler = &Dashboard{Topic: topic}
    }
    c.AddHandler(handler.HandleMessage)
    return