2 Bf Z d dl Z d dlZ d dlZddlmZ G d de Zy# e$ r dZY w xY w) N )
PubSubManagerc d e Zd ZdZdZ d fd Z fdZd Zd Zd Z d Z
d Z d
Z d Z
xZS )
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.
: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()``.
kombuc t t d t t | ||| || _ |xs i | _ |xs i | _ |xs i | _ |xs i | _ | j | _ y )NzLKombu package is not installed (Run "pip install kombu" in your virtualenv).)channel
write_onlylogger) r RuntimeErrorsuperr __init__urlconnection_optionsexchange_options
queue_optionsproducer_options _producerproducer)
selfr r r
r r r r r __class__s
V/var/www/highfloat_scraper/venv/lib/python3.12/site-packages/socketio/kombu_manager.pyr zKombuManager.__init__0 s = . /
/ lD*76@28 + : "4": 0 6B * 0b 0 6B (
c t t | d}| j j dk( rddlm} |d }n&d| j j v rddlm} |d }|s"t d| j j z y ) NTeventletr )is_monkey_patchedsocketgevent)is_module_patchedz /J
I ++L9 .U "'))$)"7
%oo- . . .
//
I ",, .H I
I s: C CC)z#amqp://guest:guest@localhost:5672//socketioFNNNNN)__name__
__module__ __qualname____doc__namer r r) r1 r9 r rI rN rZ
__classcell__)r s @r r r sN B D@>B;?6:)$
2 E7
D DF$ Ir r )rJ r5 r ImportErrorpubsub_managerr r r< r r rd s>
*nI= nI
Es **