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) {