up

pyMonit/main.go

@@ -5,6 +5,7 @@ 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"
+	"go-queue-server/pyMonit/api-service-log"
 	_ "sync"
 	_ "sync"
 	_ "time"
 	_ "time"
 )
 )
@@ -22,7 +23,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
 }
 }
 
 
@@ -73,8 +74,8 @@ func main() {
 	t := &RecvPro{}
 	t := &RecvPro{}
 
 
 	rabbitmq.Recv(rabbitmq.QueueExchange{
 	rabbitmq.Recv(rabbitmq.QueueExchange{
-		"sz_api_service_log",
-		"sz_api_service_log",
+		"api_service_log",
+		"api_service_log",
 		"",
 		"",
 		"",
 		"",
 		"amqp://WmsQue:EizM9I1TAxoO0tmzoOm@172.18.137.33:5672/",
 		"amqp://WmsQue:EizM9I1TAxoO0tmzoOm@172.18.137.33:5672/",