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) } }