def broadcast(self, command, arguments=None, destination=None, connection=None, reply=False, timeout=1.0, limit=None, callback=None, channel=None, pattern=None, matcher=None, **extra_kwargs):
    'Broadcast a control command to the celery workers.\n\n        Arguments:\n            command (str): Name of command to send.\n            arguments (Dict): Keyword arguments for the command.\n            destination (List): If set, a list of the hosts to send the\n                command to, when empty broadcast to all workers.\n            connection (kombu.Connection): Custom broker connection to use,\n                if not set, a connection will be acquired from the pool.\n            reply (bool): Wait for and return the reply.\n            timeout (float): Timeout in seconds to wait for the reply.\n            limit (int): Limit number of replies.\n            callback (Callable): Callback called immediately for\n                each reply received.\n            pattern (str): Custom pattern string to match\n            matcher (Callable): Custom matcher to run the pattern to match\n        '
    with self.app.connection_or_acquire(connection) as conn:
        arguments = dict((arguments or {}), **extra_kwargs)
        if (pattern and matcher):
            return self.mailbox(conn)._broadcast(command, arguments, destination, reply, timeout, limit, callback, channel=channel, pattern=pattern, matcher=matcher)
        else:
            return self.mailbox(conn)._broadcast(command, arguments, destination, reply, timeout, limit, callback, channel=channel)
Broadcast a control command to the celery workers.

Arguments:
    command (str): Name of command to send.
    arguments (Dict): Keyword arguments for the command.
    destination (List): If set, a list of the hosts to send the
        command to, when empty broadcast to all workers.
    connection (kombu.Connection): Custom broker connection to use,
        if not set, a connection will be acquired from the pool.
    reply (bool): Wait for and return the reply.
    timeout (float): Timeout in seconds to wait for the reply.
    limit (int): Limit number of replies.
    callback (Callable): Callback called immediately for
        each reply received.
    pattern (str): Custom pattern string to match
    matcher (Callable): Custom matcher to run the pattern to match
def broadcast(self, command, arguments=None, destination=None, connection=None, reply=False, timeout=1.0, limit=None, callback=None, channel=None, pattern=None, matcher=None, **extra_kwargs):
    'Broadcast a control command to the celery workers.\n\n        Arguments:\n            command (str): Name of command to send.\n            arguments (Dict): Keyword arguments for the command.\n            destination (List): If set, a list of the hosts to send the\n                command to, when empty broadcast to all workers.\n            connection (kombu.Connection): Custom broker connection to use,\n                if not set, a connection will be acquired from the pool.\n            reply (bool): Wait for and return the reply.\n            timeout (float): Timeout in seconds to wait for the reply.\n            limit (int): Limit number of replies.\n            callback (Callable): Callback called immediately for\n                each reply received.\n            pattern (str): Custom pattern string to match\n            matcher (Callable): Custom matcher to run the pattern to match\n        '
    with self.app.connection_or_acquire(connection) as conn:
        arguments = dict((arguments or {}), **extra_kwargs)
        if (pattern and matcher):
            return self.mailbox(conn)._broadcast(command, arguments, destination, reply, timeout, limit, callback, channel=channel, pattern=pattern, matcher=matcher)
        else:
            return self.mailbox(conn)._broadcast(command, arguments, destination, reply, timeout, limit, callback, channel=channel)