diff --git a/artemis/cleanup.py b/artemis/cleanup.py index 081267477..17ca5265d 100644 --- a/artemis/cleanup.py +++ b/artemis/cleanup.py @@ -66,6 +66,8 @@ def process(self, task: Task) -> None: def loop(self) -> None: self.log.info("The service that removes %s tasks from the queue started", self.identity) + self.backend.register_bind(self._bind) + while True: task = self.backend.consume_routed_task(self.identity) if not task: