From f2c4dc97e7c84ccdaa1a7b3624180af7de05176e Mon Sep 17 00:00:00 2001
From: eson <9673575+githubcontent@user.noreply.gitee.com>
Date: Tue, 29 Aug 2023 15:28:03 +0800
Subject: [PATCH] fix

---
 initalize/rabbitmq.go               | 8 +++-----
 server/websocket/etc/websocket.yaml | 2 +-
 2 files changed, 4 insertions(+), 6 deletions(-)

diff --git a/initalize/rabbitmq.go b/initalize/rabbitmq.go
index 58a26645..8a114806 100644
--- a/initalize/rabbitmq.go
+++ b/initalize/rabbitmq.go
@@ -6,10 +6,11 @@ import (
 	"errors"
 	"fusenapi/constants"
 	"fusenapi/utils/mq_consumer_factory"
-	"github.com/streadway/amqp"
-	"github.com/zeromicro/go-zero/core/logx"
 	"log"
 	"sync"
+
+	"github.com/streadway/amqp"
+	"github.com/zeromicro/go-zero/core/logx"
 )
 
 type RabbitMqHandle struct {
@@ -25,9 +26,6 @@ type queueItem struct {
 var mapMq = make(map[constants.RABBIT_MQ]queueItem)
 
 func InitRabbitMq(url string, config *tls.Config) *RabbitMqHandle {
-	if url == "" {
-		return nil
-	}
 	conn, err := amqp.DialTLS(url, config)
 	if err != nil {
 		log.Fatalf("Failed to connect to RabbitMQ: %v", err)
diff --git a/server/websocket/etc/websocket.yaml b/server/websocket/etc/websocket.yaml
index 541de5e4..1ad7f5dd 100644
--- a/server/websocket/etc/websocket.yaml
+++ b/server/websocket/etc/websocket.yaml
@@ -10,7 +10,7 @@ Auth:
     AccessSecret: fusen2023
     AccessExpire: 2592000
     RefreshAfter: 1592000
-SourceRabbitMq:   #amqp://rabbit001:rabbit001129@110.41.19.98:5672
+SourceRabbitMq:   amqp://rabbit001:rabbit001129@110.41.19.98:5672
 AWS:
     S3:
         Credentials: