From 1733238a83bf5a42c64c62b021be22764a323d24 Mon Sep 17 00:00:00 2001
From: Clement Li <lizi4@huawei.com>
Date: Tue, 2 Nov 2021 17:46:48 +0800
Subject: [PATCH] fix autoAck

---
 src/server.go | 37 +++++++++++++++++++------------------
 1 file changed, 19 insertions(+), 18 deletions(-)

diff --git a/src/server.go b/src/server.go
index 58c196e..f2ae786 100644
--- a/src/server.go
+++ b/src/server.go
@@ -2,6 +2,7 @@ package main
 
 import (
 	"log"
+	"os"
 	"time"
 
 	gitee_utils "gitee.com/lizi/test-bot/src/gitee-utils"
@@ -9,24 +10,24 @@ import (
 
 func doRabbitMQ() {
 
-	// RMQ_QUEUE_NAME := os.Getenv("RMQ_QUEUE_NAME")
-	// RMQ_HOST := os.Getenv("RMQ_HOST")
-	// RMQ_VHOST := os.Getenv("RMQ_VHOST")
-	// RMQ_USER := os.Getenv("RMQ_USER")
-	// RMQ_PASS := os.Getenv("RMQ_PASS")
-	// RMQ_PORT := os.Getenv("RMQ_PORT")
-	// RMQ_ROUTINGKEY := os.Getenv("RMQ_ROUTINGKEY")
-	// RMQ_EXCHANGE_NAME := os.Getenv("RMQ_EXCHANGE_NAME")
-	// RMQ_EXCHANGE_TYPE := os.Getenv("RMQ_EXCHANGE_TYPE")
+	RMQ_QUEUE_NAME := os.Getenv("RMQ_QUEUE_NAME")
+	RMQ_HOST := os.Getenv("RMQ_HOST")
+	RMQ_VHOST := os.Getenv("RMQ_VHOST")
+	RMQ_USER := os.Getenv("RMQ_USER")
+	RMQ_PASS := os.Getenv("RMQ_PASS")
+	RMQ_PORT := os.Getenv("RMQ_PORT")
+	RMQ_ROUTINGKEY := os.Getenv("RMQ_ROUTINGKEY")
+	RMQ_EXCHANGE_NAME := os.Getenv("RMQ_EXCHANGE_NAME")
+	RMQ_EXCHANGE_TYPE := os.Getenv("RMQ_EXCHANGE_TYPE")
 
 	// RabbitMQ
 	rc := gitee_utils.RabbitConfig{
 		Schema:         "amqp",
-		Username:       "guest",
-		Password:       "guest",
-		Host:           "140.83.83.152",
-		Port:           "8090",
-		VHost:          "",
+		Username:       RMQ_USER,
+		Password:       RMQ_PASS,
+		Host:           RMQ_HOST,
+		Port:           RMQ_PORT,
+		VHost:          RMQ_VHOST,
 		ConnectionName: "",
 	}
 	rbt := gitee_utils.NewRabbit(rc)
@@ -36,10 +37,10 @@ func doRabbitMQ() {
 
 	// Consumer
 	cc := gitee_utils.ConsumerConfig{
-		ExchangeName:  "lz.direct",
-		ExchangeType:  "direct",
-		RoutingKey:    "lz.issue",
-		QueueName:     "lz.issue",
+		ExchangeName:  RMQ_EXCHANGE_NAME,
+		ExchangeType:  RMQ_EXCHANGE_TYPE,
+		RoutingKey:    RMQ_ROUTINGKEY,
+		QueueName:     RMQ_QUEUE_NAME,
 		ConsumerCount: 1,
 		PrefetchCount: 1,
 	}
-- 
Gitee