remove deprecated amqp mod, added official amqp mod

This commit is contained in:
Piotr Biernat 2024-07-16 18:54:28 +02:00
parent 050aef8b7a
commit 3ed094ff55

View File

@ -3,7 +3,7 @@ package rabbitmq
import ( import (
"log" "log"
"github.com/streadway/amqp" amqp "github.com/rabbitmq/amqp091-go"
) )
func Open(url string) (*amqp.Connection, *amqp.Channel, error) { func Open(url string) (*amqp.Connection, *amqp.Channel, error) {