浏览代码

debug changes

Abhishek Kondur 1 年之前
父节点
当前提交
b8f0108127
共有 1 个文件被更改,包括 1 次插入0 次删除
  1. 1 0
      mq/util.go

+ 1 - 0
mq/util.go

@@ -75,6 +75,7 @@ func encryptMsg(host *models.Host, msg []byte) ([]byte, error) {
 
 func publish(host *models.Host, dest string, msg []byte) error {
 	if len(msg) == 0 {
+		fmt.Println("----->  $$$$$$ ZERO MSG_-------> ", string(msg))
 		pc, _, _, ok := runtime.Caller(1)
 		details := runtime.FuncForPC(pc)
 		if ok && details != nil {