This document is for Kombu's development version, which can be significantly different from previous releases. Get the stable docs here: 5.0.
Pyro Transport - kombu.transport.pyro
¶
Pyro transport module for kombu.
Pyro transport, and Kombu Broker daemon.
Requires the Pyro4
library to be installed.
Features¶
Type: Virtual
Supports Direct: Yes
Supports Topic: Yes
Supports Fanout: No
Supports Priority: No
Supports TTL: No
Connection String¶
To use the Pyro transport with Kombu, use an url of the form:
pyro://localhost/kombu.broker
The hostname is where the transport will be looking for a Pyro name server,
which is used in turn to locate the kombu.broker Pyro service.
This broker can be launched by simply executing this transport module directly,
with the command: python -m kombu.transport.pyro
Transport Options¶
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.
-
close
()¶ Close channel.
Cancel all consumers, and requeue unacked messages.
-
queues
()¶
-
-
default_port
= 9090¶ port number used when no port is specified.
-
driver_name
= 'pyro'¶ Name of driver library (e.g. ‘py-amqp’, ‘redis’).
-
driver_type
= 'pyro'¶ Type of driver, can be used to separate transports using the AMQP protocol (driver_type: ‘amqp’), Redis (driver_type: ‘redis’), etc…
-
global_state
= <kombu.transport.virtual.base.BrokerState object>¶
-
class