def METHOD_NAME(self):
    self.simple_queue_setup()
    step = Mock(spec=['route_for_task'])
    step.route_for_task.return_value = None
    R = routes.prepare([step])
    router = Router(self.app, R, self.app.amqp.queues)
    self.mytask.apply_async((2, 2), {'kw': 3}, router=router, priority=3)
    step.route_for_task.assert_called_with(
        self.mytask.name, (2, 2), {'kw': 3},
    )