iD d d dl Z d dlZ d dlZn
# e$ r dZY nw xY wddlmZ G d de ZdS ) N )
PubSubManagerc ^ e Zd ZdZdZ d fd Z fdZd Zd
Zd Z d Z
d
Z d Z xZ
S ) KombuManagera 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 `_.
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
`_ 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 to ``True``, only initialize to emit events. The
default of ``False`` initializes the class for emitting
and receiving. A write-only instance can be used
independently of the server to emit to clients from an
external process.
:param logger: a custom logger to log it. If not given, the server logger
is used.
:param json: An alternative JSON module to use for encoding and decoding
packets. Custom json modules must have ``dumps`` and ``loads``
functions that are compatible with the standard library
versions. This setting is only used when ``write_only`` is set
to ``True``. Otherwise the JSON module configured in the
server is used.
:param connection_options: additional keyword arguments to be passed to
``kombu.Connection()``.
:param exchange_options: additional keyword arguments to be passed to
``kombu.Exchange()``.
:param queue_options: additional keyword arguments to be passed to
``kombu.Queue()``.
:param producer_options: additional keyword arguments to be passed to
``kombu.Producer()``.
kombu#amqp://guest:guest@localhost:5672//socketioFNc
t t d t |||| || _ |pi | _ |pi | _ |pi | _ | pi | _ | | _
d S )NzLKombu package is not installed (Run "pip install kombu" in your virtualenv).)channel
write_onlyloggerjson) r RuntimeErrorsuper__init__urlconnection_optionsexchange_options
queue_optionsproducer_options _connectionpublisher_connection) selfr r r r
r r r r r __class__s A/usr/local/lib/python3.11/dist-packages/socketio/kombu_manager.pyr zKombuManager.__init__: s = . / /
/ Z " $ $ $"4": 0 6B * 0b 0 6B $($4$4$6$6!!! c
t d}| j j dk rddlm} |d }n d| j j v rddlm} |d }|s t d| j j z d S ) NTeventletr )is_monkey_patchedsocketgevent)is_module_patchedz #66t,---~dl66g666r c dt t j z }dddid}| | j t j || fi |S )Nzpython-socketio.Fz x-expiresi )r. queue_arguments)struuiduuid4r/ r r Queuer2 )r
queue_namer1 s r _queuezKombuManager._queueb se '#djll*;*;;
#f8MNNt)***{:t~~'7'7CC7CCCr c |j dd| i| j }| ||j S )Nexchange )Producerr2 r ensurepublish)r
connectionproducers r _producer_publishz KombuManager._producer_publishh sU &:& @ @0@0@ @)-)>@ @ 8+;<<rh s LLLL EEE * ) ) ) ) )D7 D7 D7 D7 D7= D7 D7 D7 D7 D7s