Accomodate pamqp 3.0 changes

FAForever · Jun 4, 2024 · c77f085 · c77f085
1 parent 557ded5
commit c77f085
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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,