queue ends with localhost

cenkalti · Oct 28, 2016 · a67e6e5 · a67e6e5
1 parent 7dc8c8e
commit a67e6e5
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 3 deletions.
diff --git a/docs/changelog.rst b/docs/changelog.rst
@@ -20,7 +20,7 @@ Released on XXX
 - Removed local argument from Task.send_to_queue method.
   Pass host="localhost" for sending to local queue.
 - Removed local argument from worker command.
-  If queue name ends with "." hostname will be appended to queue name.
+  If queue name ends with ".localhost" hostname will be appended to queue name.
 - Removed deprecated Worker.queue property.
 
 Version 5.1.0

diff --git a/kuyruk/__main__.py b/kuyruk/__main__.py
@@ -36,7 +36,8 @@ def main():
         default=[],
         action='append',
         help='consume tasks from queue (may be specified multiple times), '
-        'if queue name ends with "." hostname will be appended to queue name')
+        'if queue name ends with ".localhost" hostname will be appended '
+        'to queue name')
     parser_worker.add_argument(
         '--max-load',
         type=float,

diff --git a/kuyruk/worker.py b/kuyruk/worker.py
@@ -34,7 +34,8 @@ def __init__(self, app, args):
             args.queues = ['kuyruk']
 
         def add_host(queue):
-            if queue.endswith('.'):
+            if queue.endswith('.localhost'):
+                queue = queue.rsplit('.localhost')[0]
                 return "%s.%s" % (queue, self._hostname)
             else:
                 return queue