基于serf的数据库同步模块库
liuxiaolong
2019-10-08 9e9867a0f667b77648ac4a7881f7a596c363536e
userDelegate.go
@@ -23,6 +23,8 @@
func (d *UserDelegate) NotifyMsg(msg []byte) {
   recvMsg := msg
   logger.Info("UserDelegate NotifyMsg.len:",len(recvMsg))
   QueryTcpResponseChan <- msg
   var dumpSqls []string
   err := json.Unmarshal(recvMsg, &dumpSqls)