def METHOD_NAME(function, queue: str = None, arguments: Dict = None):
    if settings.AWS_SQS:
        raise NotImplementedError("SQS does not support the broadcast at the moment.")
    else:
        if queue:
            if queue not in settings.CELERY_QUEUES:
                queue = DEFAULT_QUEUE
            queue = [f"celery@worker_{queue}"]
        app.control.METHOD_NAME(function.__name__, destination=queue, arguments=arguments)