code: def handle_delayed_messages(self):
          
          for eta, message in iter_queue(self.delay_queue):
              if eta > current_millis():
                  self.delay_queue.put((eta, message))
                  self.delay_queue.task_done()
                  break
  
              queue_name = q_name(message.queue_name)
              new_message = message.copy(queue_name=queue_name)
              del new_message.options["eta"]
  
              self.broker.enqueue(new_message)
              self.post_process_message(message)
              self.delay_queue.task_done()
docs: Enqueue any delayed messages whose eta has passed.