ruleserver/server.go
@@ -4,7 +4,7 @@ "basic.com/pubsub/protomsg.git" "basic.com/valib/gopherdiscovery.git" "github.com/gogo/protobuf/proto" logger "github.com/alecthomas/log4go" "basic.com/valib/logger.git" "time" ) @@ -52,7 +52,7 @@ //广播数据库改变的msg func publishMessage(msg *protomsg.VideotapeInfo) { sendBytes,err := proto.Marshal(msg) if err ==nil{ if err == nil{ discoveryServer.PublishMsg(string(sendBytes)) } }