remove deprecated amqp mod, added official amqp mod

2024-07-16 18:54:28 +02:00
1 changed files with 1 additions and 1 deletions
--- 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) {