up

pyMonit/main.go

@@ -5,7 +5,6 @@ import (
 	"fmt"
 	"fmt"
 	"github.com/ichunt2019/golang-rbmq-sl/utils/rabbitmq"
 	"github.com/ichunt2019/golang-rbmq-sl/utils/rabbitmq"
 	"go-queue-server/dal/db"
 	"go-queue-server/dal/db"
-	api_service_log "go-queue-server/pyMonit/api-service-log"
 	_ "sync"
 	_ "sync"
 	_ "time"
 	_ "time"
 )
 )
@@ -23,7 +22,7 @@ type RecvPro struct {
 //// 实现消费者 消费消息失败 自动进入延时尝试  尝试3次之后入库db
 //// 实现消费者 消费消息失败 自动进入延时尝试  尝试3次之后入库db
 func (t *RecvPro) Consumer(dataByte []byte) error {
 func (t *RecvPro) Consumer(dataByte []byte) error {
 	fmt.Println(string(dataByte))
 	fmt.Println(string(dataByte))
-	api_service_log.AddMsgtoRbmq(string(dataByte))
+	//api_service_log.AddMsgtoRbmq(string(dataByte))
 	return nil
 	return nil
 }
 }