554325746@qq.com
2020-02-04 fe0d2a7aec5984d0931ab81e1af4921fb2c6f83c
pubsub.go
@@ -10,6 +10,7 @@
}
type Message struct {
   Id string
   Topic string
   Msg []byte
}
@@ -18,6 +19,7 @@
   Topic_Camera = "camera"  //摄像机消息
   Topic_Task = "task" //任务消息
   Topic_Sdk = "sdk" //算法消息
    Topic_RuleProc = "ruleProcess" //ruleProcess消息
   Topic_Event = "event" //事件消息
)
@@ -28,4 +30,4 @@
//processId is process Identifier,unique
func NewSubscriber(url string,heartBeatUrl string,mode int,topics []string,processId string) (PubSub,error) {
   return newSub(url,heartBeatUrl, topics, processId)
}
}