Module Import alias Import alias TryExcept body Import alias handlers ExceptHandler type NameLoad body Assign NameStore NameLoad ImportFrom alias ClassDef bases NameLoad body Expr Str Assign NameStore Str FunctionDef arguments args NameParam NameParam NameParam NameParam defaults Str Str NameLoad body If CompareIs NameLoad NameLoad body Raise Call NameLoad Str Expr Call AttributeLoad Call NameLoad NameLoad NameLoad attr keyword NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults NameLoad body Assign NameStore Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr keyword Str keyword NameLoad Assign NameStore Call AttributeLoad NameLoad attr Call NameLoad Call AttributeLoad NameLoad attr NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body With Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr NameStore body Expr Call AttributeLoad NameLoad attr Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad NameLoad attr NameLoad With Call AttributeLoad NameLoad attr NameLoad NameStore body While NameLoad body Assign NameStore Call AttributeLoad NameLoad attr keyword NameLoad Expr Call AttributeLoad NameLoad attr Expr Yield AttributeLoad NameLoad attr decorator_list decorator_list
N/A N/A pickle N/A uuid N/A N/A N/A kombu N/A N/A N/A ImportError N/A N/A kombu None pubsub_manager PubSubManager KombuManager N/A PubSubManager N/A N/A Client manager that uses kombu for inter-process messaging.

    This class implements a client manager backend for event sharing across
    multiple processes, using RabbitMQ, Redis or any other messaging mechanism
    supported by `kombu <http://kombu.readthedocs.org/en/latest/>`_.

    To use a kombu backend, initialize the :class:`Server` instance as
    follows::

        url = 'amqp://user:password@hostname:port//'
        server = socketio.Server(client_manager=socketio.KombuManager(url))

    :param url: The connection URL for the backend messaging queue. Example
                connection URLs are ``'amqp://guest:guest@localhost:5672//'``
                and ``'redis://localhost:6379/'`` for RabbitMQ and Redis
                respectively. Consult the `kombu documentation
                <http://kombu.readthedocs.org/en/latest/userguide                /connections.html#urls>`_ for more on how to construct
                connection URLs.
    :param channel: The channel name on which the server sends and receives
                    notifications. Must be the same in all the servers.
    :param write_only: If set ot ``True``, only initialize to emit events. The
                       default of ``False`` initializes the class for emitting
                       and receiving.
     N/A name kombu __init__ N/A N/A self url channel write_only N/A amqp://guest:guest@localhost:5672// socketio False N/A N/A N/A kombu None N/A N/A N/A RuntimeError Kombu package is not installed (Run "pip install kombu" in your virtualenv). N/A N/A N/A N/A super KombuManager self __init__ channel channel N/A N/A self url url N/A N/A self writer_conn N/A N/A kombu Connection N/A self url N/A N/A self writer_queue N/A N/A self _queue N/A self writer_conn N/A _queue N/A N/A self conn N/A None N/A N/A exchange N/A N/A kombu Exchange N/A self channel type fanout durable False N/A queue N/A N/A kombu Queue N/A str N/A N/A uuid uuid4 exchange N/A queue N/A _publish N/A N/A self data N/A N/A N/A N/A N/A N/A self writer_conn SimpleQueue N/A self writer_queue queue N/A N/A N/A N/A queue put N/A N/A pickle dumps data N/A _listen N/A N/A self N/A N/A N/A reader_conn N/A N/A kombu Connection N/A self url N/A reader_queue N/A N/A self _queue reader_conn N/A N/A N/A reader_conn SimpleQueue reader_queue queue N/A N/A True N/A N/A message N/A N/A queue get block True N/A N/A N/A message ack N/A N/A N/A message payload N/A N/A