Merge pull request #523 from Olegt0rr/fix-queue-name

Fixed `queue_name` was set as `channel_name`
mosquito · Feb 18, 2023 · 3e43331 · 3e43331
2 parents fe1cbce + 1b927b3
commit 3e43331
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/.github/workflows/tests.yml b/.github/workflows/tests.yml
@@ -96,7 +96,7 @@ jobs:
       - run: poetry run coveralls
         env:
           COVERALLS_PARALLEL: 'true'
-          COVERALLS_REPO_TOKEN: ${{ secrets.COVERALLS_REPO_TOKEN }}
+          COVERALLS_SERVICE_NAME: github
           GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
 
   finish:

diff --git a/aio_pika/patterns/master.py b/aio_pika/patterns/master.py
@@ -169,16 +169,16 @@ async def on_message(
                 await message.nack(requeue=e.requeue)
 
     async def create_queue(
-        self, channel_name: str, **kwargs: Any,
+        self, queue_name: str, **kwargs: Any,
     ) -> AbstractQueue:
-        return await self.channel.declare_queue(channel_name, **kwargs)
+        return await self.channel.declare_queue(queue_name, **kwargs)
 
     async def create_worker(
-        self, channel_name: str, func: Callable[..., Any], **kwargs: Any,
+        self, queue_name: str, func: Callable[..., Any], **kwargs: Any,
     ) -> Worker:
         """ Creates a new :class:`Worker` instance. """
 
-        queue = await self.create_queue(channel_name, **kwargs)
+        queue = await self.create_queue(queue_name, **kwargs)
 
         if hasattr(func, "_is_coroutine"):
             fn = func