This document describes the current stable version of Kombu (5.0). For development docs, go here.
Pyro Transport - kombu.transport.pyro
¶
Pyro transport, and Kombu Broker daemon.
Requires the Pyro4
library to be installed.
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¶
- 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…
- state = <kombu.transport.virtual.base.BrokerState object>¶
memory backend state is global.