fix 循环依赖的问题

This commit is contained in:
陈景阳
2019-10-28 13:51:12 +08:00
parent 070242c5a2
commit 7a5fd69949
2 changed files with 1 additions and 22 deletions

View File

@@ -40,7 +40,7 @@ func (g *Log) get() error {
msgSd.Log = utils.BytesToString(logStr)
}
// 发布消息给主节点
if err := utils.Pub(constants.ChannelMasterNode, msgSd); err != nil {
if err := database.Pub(constants.ChannelMasterNode, msgSd); err != nil {
log.Errorf("pub log to master node error: %s", err.Error())
debug.PrintStack()
return err