gt-common/rabbitMQ/rabbitmq.go

package rabbitMQ

import (
	"github.com/streadway/amqp"
)

func NewConnect(url string) (*amqp.Connection, error) {
	conn, err := amqp.Dial(url)
	if err != nil {
		println("new rabbitMQ connect error: ", err.Error())
	}

	return conn, err
}