This document describes the current stable version of Kombu (4.2). For development docs, go here.
Pyro Transport - kombu.transport.pyro
¶
Pyro transport.
Requires the Pyro4
library to be installed.
Transport¶
-
class
kombu.transport.pyro.
Transport
(client, **kwargs)[source]¶ Pyro Transport.
-
class
Channel
(connection, **kwargs)¶ Pyro Channel.
-
after_reply_message_received
(queue)¶ Callback called after RPC reply received.
Notes
Reply queue semantics: can be used to delete the queue after transient reply message received.
-
queues
()¶
-
-
default_port
= 9090¶
-
driver_name
= 'pyro'¶
-
driver_type
= 'pyro'¶
-
state
= <kombu.transport.virtual.base.BrokerState object>¶ memory backend state is global.
-
class