This commit is contained in:
laodaming 2023-08-29 15:30:54 +08:00
parent d0acec05fa
commit df6e4a0899

View File

@ -9,6 +9,7 @@ import (
"github.com/streadway/amqp"
"github.com/zeromicro/go-zero/core/logx"
"log"
"strings"
"sync"
)
@ -25,6 +26,7 @@ type queueItem struct {
var mapMq = make(map[constants.RABBIT_MQ]queueItem)
func InitRabbitMq(url string, config *tls.Config) *RabbitMqHandle {
url = strings.Trim(url, " ")
if url == "" {
return nil
}