|
@@ -84,7 +84,7 @@ func PrepareTimeWindowProducerQueue() {
|
|
|
subscriber2, err := goroslib.NewSubscriber(goroslib.SubscriberConf{
|
|
|
Node: cfg.RosNode,
|
|
|
Topic: masterConfig.TopicOfSysInfo,
|
|
|
- Callback: func(data *ros_message.SysInfo) {
|
|
|
+ Callback: func(data *pji_msgs.SysInfo) {
|
|
|
//log.GlobalLogger.Info("话题", masterConfig.TopicOfSysInfo, "接收到数据", data)
|
|
|
subscriber2Mutex.Lock()
|
|
|
{
|
|
@@ -110,7 +110,7 @@ func PrepareTimeWindowProducerQueue() {
|
|
|
subscriber3, err := goroslib.NewSubscriber(goroslib.SubscriberConf{
|
|
|
Node: cfg.RosNode,
|
|
|
Topic: masterConfig.TopicOfLocateInfo,
|
|
|
- Callback: func(data *ros_message.LocateInfo) {
|
|
|
+ Callback: func(data *pji_msgs.LocateInfo) {
|
|
|
//log.GlobalLogger.Info("话题", masterConfig.TopicOfLocateInfo, "接收到数据", data)
|
|
|
subscriber3Mutex.Lock()
|
|
|
{
|