Merge pull request #161 from sunmi-OS/feature/v1.5-patch

Feature/v1.5 patch

rabbitmq/rabbitmq.go

@@ -18,14 +18,19 @@ func connRbbitmq() error {
 	vhost := viper.GetEnvConfig("rabbitmq.vhost")
 	user := url.QueryEscape(viper.GetEnvConfig("rabbitmq.user"))
 	password := url.QueryEscape(viper.GetEnvConfig("rabbitmq.password"))
+	scheme := "amqp"
+	enableTLS := viper.GetEnvConfigBool("rabbitmq.enableTLS")
+	if enableTLS {
+		scheme = "amqps"
+	}
 
-	amqpcoinf := amqp.Config{
+	amqpConfig := amqp.Config{
 		Vhost:     vhost,
 		Heartbeat: 10 * time.Second,
 		Locale:    "en_US",
 	}
 
-	conn, err := amqp.DialConfig(fmt.Sprintf("amqp://%s:%s@%s:%s/", user, password, host, port), amqpcoinf)
+	conn, err := amqp.DialConfig(fmt.Sprintf("%s://%s:%s@%s:%s/", scheme, user, password, host, port), amqpConfig)
 	if err != nil {
 		return err
 	}