From 3ed094ff55e0df0514a29c5d68e49ac4857f2926 Mon Sep 17 00:00:00 2001 From: Piotr Biernat Date: Tue, 16 Jul 2024 18:54:28 +0200 Subject: [PATCH] remove deprecated amqp mod, added official amqp mod --- rabbitmq/connect.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/rabbitmq/connect.go b/rabbitmq/connect.go index cddfa22..8036b72 100644 --- a/rabbitmq/connect.go +++ b/rabbitmq/connect.go @@ -3,7 +3,7 @@ package rabbitmq import ( "log" - "github.com/streadway/amqp" + amqp "github.com/rabbitmq/amqp091-go" ) func Open(url string) (*amqp.Connection, *amqp.Channel, error) {