From 79a7b5668625b73f6bfe6710c344aee704b596e8 Mon Sep 17 00:00:00 2001
From: liuxiaolong <736321739@qq.com>
Date: 星期三, 27 十一月 2019 11:31:12 +0800
Subject: [PATCH] add log
---
server.go | 8 +++++---
1 files changed, 5 insertions(+), 3 deletions(-)
diff --git a/server.go b/server.go
index 7abaf58..404fb40 100644
--- a/server.go
+++ b/server.go
@@ -26,6 +26,8 @@
var env = flag.String("env", "config", "env set")
var mqIp = flag.String("mqIp", "172.17.50.245", "default mq ip")
var mqPort = flag.Int("mqPort", 5672, "default mq port")
+var mqUser = flag.String("mqUser", "basic", "default rabbitmq user")
+var mqPass = flag.String("mqPass", "basic", "default rabbitmq pass")
func main() {
flag.Parse()
@@ -56,8 +58,8 @@
// go handleConnection(conn,connArr)
//}
+ mqAddr := "amqp://" + *mqUser + ":" + *mqPass + "@" + *mqIp + ":" + strconv.Itoa(*mqPort)+"/"
- mqAddr := "amqp://guest:guest@" + *mqIp + ":" + strconv.Itoa(*mqPort)+"/"
conn, err := amqp.Dial(mqAddr)
if err != nil {
log.Log.Infof("Failed to connect to RabbitMQ,err:",err)
@@ -106,9 +108,9 @@
Body: alarmData,
})
if err !=nil {
- log.Log.Infof("send to mq err:",err)
+ log.Log.Infof("send to mq err:"+err.Error())
} else {
- log.Log.Infof("send to mq success,len(body):",len(alarmData))
+ log.Log.Infof("send to mq success,msg: "+string(alarmData))
}
}
lastTime = curTime
--
Gitblit v1.8.0