kombu.transport.pyro
Pyro transport.
Requires the Pyro4
library to be installed.
-
class
kombu.transport.pyro.
Transport
(client, **kwargs)[source]
-
class
Channel
(connection, **kwargs)
-
after_reply_message_received
(queue)
-
queues
()
-
shared_queues
-
Transport.
default_port
= 9090
-
Transport.
driver_name
= 'pyro'
-
Transport.
driver_type
= 'pyro'
-
Transport.
driver_version
()[source]
-
Transport.
shared_queues
[source]
-
Transport.
state
= <kombu.transport.virtual.BrokerState object>
memory backend state is global.