haozhifeng
2021-07-01 9405599d67492ef207e2bb242cd116f019b861f6
logc.go
@@ -1,7 +1,7 @@
package logc
import (
   "basic.com/valib/bhomebus.git"
   "basic.com/valib/bhshmq.git/proto/source/bhome_msg"
   "fmt"
   "sync"
   "time"
@@ -44,7 +44,7 @@
}
type LogRegister struct {
   Nodes      []bhomebus.NetNode
   Nodes      []bhome_msg.BHAddress
   Topic      string
   Payload     []byte
}
@@ -180,8 +180,8 @@
         if err != nil {
            logger.Error("failed to Marshal", log)
         } else {
               var nodes []bhomebus.NetNode
               nodes = append(nodes, bhomebus.NetNode{})
               var nodes []bhome_msg.BHAddress
               nodes = append(nodes, bhome_msg.BHAddress{})
               reg := &LogRegister {
                  nodes,