This document is for Kombu's development version, which can be
significantly different from previous releases. Get the stable docs here:
3.0.
Pyro Transport - kombu.transport.pyro
Pyro transport.
Requires the Pyro4 library to be installed.
-
class
kombu.transport.pyro.Transport(client, **kwargs)[source]
Pyro Transport.
-
class
Channel(connection, **kwargs)
Pyro Channel.
-
after_reply_message_received(queue)
-
queues()
-
shared_queues
-
default_port = 9090
-
driver_name = 'pyro'
-
driver_type = 'pyro'
-
driver_version()[source]
-
shared_queues[source]
-
state = <kombu.transport.virtual.base.BrokerState object>
memory backend state is global.
-
class
kombu.transport.pyro.Channel(connection, **kwargs)[source]
Pyro Channel.
-
after_reply_message_received(queue)[source]
-
queues()[source]
-
shared_queues[source]
