From c77f085e62cedcc03e5fe2784d09d71c1b012e88 Mon Sep 17 00:00:00 2001
From: BlackYps <jonas-fb@gmx.de>
Date: Tue, 4 Jun 2024 15:38:00 +0200
Subject: [PATCH] Accomodate pamqp 3.0 changes

---
 service/message_queue_service.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/service/message_queue_service.py b/service/message_queue_service.py
index b503cbf..77df983 100644
--- a/service/message_queue_service.py
+++ b/service/message_queue_service.py
@@ -5,7 +5,7 @@
 import aio_pika
 from aio_pika import DeliveryMode, ExchangeType
 from aio_pika.exceptions import ProbableAuthenticationError
-from pamqp import specification
+from pamqp import commands
 
 from service import config
 from service.decorators import with_logger
@@ -114,7 +114,7 @@ async def publish(
         )
 
         confirmation = await exchange.publish(message, routing_key=routing)
-        if not isinstance(confirmation, specification.Basic.Ack):
+        if not isinstance(confirmation, commands.Basic.Ack):
             self._logger.warning(
                 "Message could not be delivered to %s, received %s",
                 routing,