23 lines
458 B
Go
23 lines
458 B
Go
// Package mq define message queue operation functions
|
|
package mq
|
|
|
|
import (
|
|
"fmt"
|
|
|
|
"eventRT/config"
|
|
|
|
"github.com/streadway/amqp"
|
|
)
|
|
|
|
func InitRabbitMQ(rCfg config.RabbitMQConfig) *amqp.Connection {
|
|
url := fmt.Sprintf("amqp://%s:%s@%s:%d/", rCfg.User, rCfg.Password, rCfg.Host, rCfg.Port)
|
|
if rCfg.URL != "" {
|
|
url = rCfg.URL
|
|
}
|
|
conn, err := amqp.Dial(url)
|
|
if err != nil {
|
|
panic(fmt.Errorf("failed to connect to RabbitMQ: %w", err))
|
|
}
|
|
return conn
|
|
}
|