diff --git a/tests/test_amqp.py b/tests/test_amqp.py index 06da7e0e..ac737e8d 100644 --- a/tests/test_amqp.py +++ b/tests/test_amqp.py @@ -10,6 +10,7 @@ import pytest import shortuuid +from aiormq import ChannelLockedResource import aio_pika import aio_pika.exceptions @@ -1404,6 +1405,19 @@ async def test_delivery_fail(self): routing_key=queue.name ) + async def test_channel_locked_resource(self): + ch1 = await self.create_channel() + ch2 = await self.create_channel() + + qname = self.get_random_name("channel", "locked", "resource") + + q1 = await ch1.declare_queue(qname, exclusive=True) + await q1.consume(print, exclusive=True) + + with self.assertRaises(ChannelLockedResource): + q2 = await ch2.declare_queue(qname, exclusive=True) + await q2.consume(print, exclusive=True) + class MessageTestCase(unittest.TestCase): def test_message_copy(self):