|
|
@@ -36,13 +36,16 @@ func main() {
|
|
|
Name: "dpi_with_heartbeatInfo",
|
|
|
MasterAddress: "127.0.0.1:11311",
|
|
|
})
|
|
|
- _, _ = goroslib.NewSubscriber(goroslib.SubscriberConf{
|
|
|
+ _, err = goroslib.NewSubscriber(goroslib.SubscriberConf{
|
|
|
Node: rosNode,
|
|
|
Topic: "/heartbeat_info",
|
|
|
Callback: func(data *HeartBeatInfo) {
|
|
|
fmt.Println("监听到数据：", data)
|
|
|
lastTime = time.Now()
|
|
|
}})
|
|
|
+ if err != nil {
|
|
|
+ fmt.Println("监听话题/heartbeat_info报错", err)
|
|
|
+ }
|
|
|
// 3 超过5秒没有接收到数据则执行 dpi_stop.sh 和 dpi_start.sh
|
|
|
|
|
|
for {
|
