#Ii~ h S SK r S SKr S SKrS SKJr SSKJr " S S\5 rg! \ a Sr N"f = f) N)json )
PubSubManagerc l ^ \ rS rSrSrSr S
U 4S jjrU 4S jrS rS r S r
S r S
r S r
S rU =r$ ) KombuManager
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 `_.
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 > [ c [ S5 e[ T U ]
X#US9 Xl U=( d 0 U l U=( d 0 U l U=( d 0 U l U=( d 0 U l U R 5 U l
g )NzLKombu package is not installed (Run "pip install kombu" in your virtualenv).)channel
write_onlylogger) r RuntimeErrorsuper__init__urlconnection_optionsexchange_options
queue_optionsproducer_options _connectionpublisher_connection)
selfr r r r
r r r r __class__s
[ TU ] 5 SnU R R S:X a SSKJn U" S5 nO(SU R R ; a SSKJn U" S5 nU( d" [ SU R R - 5 eg ) NTeventletr )is_monkey_patchedsocketgevent)is_module_patchedz)>@ +;+;<= ('' U - - 8 89
7 "((**0&*=?
;' !+/2 6
7 s] DB B3A,,
A: 6B=B D
BB DB A7DDDD)r r r r r r )z#amqp://guest:guest@localhost:5672//socketioFNNNNN)__name__
__module__ __qualname____firstlineno____doc__namer r# r r4 r= rG rS re __static_attributes__
__classcell__)r s @r r r
sK B D@>B;?6:7
2 E7
D =
$7 7r r ) r^ r9 r ImportErrorengineior pubsub_managerr r rA r r rs s? )y7= y7 Es & 11