| | |
|---|
| | | switch topic { |
|---|
| | | case fmt.Sprintf(constvar.NsqTopicScheduleTask, conf.Conf.NsqConf.NodeId): |
|---|
| | | handler = new(ScheduleTask) |
|---|
| | | case fmt.Sprintf(constvar.NsqTopicSendPlcAddress, conf.Conf.NsqConf.NodeId): |
|---|
| | | handler = &PlcAddress{Topic: topic} |
|---|
| | | case fmt.Sprintf(constvar.NsqTopicProcessParamsResponse, conf.Conf.NsqConf.NodeId): |
|---|
| | | handler = &ProcessParams{Topic: topic} |
|---|
| | | case fmt.Sprintf(constvar.NsqTopicApsProcessParams, conf.Conf.NsqConf.NodeId): |
|---|
| | | handler = &ProcessParamsSync{Topic: topic} |
|---|
| | | case fmt.Sprintf(constvar.NsqTopicDeviceUpdate, conf.Conf.NsqConf.NodeId): |
|---|
