This document describes the current stable version of Kombu (4.5). 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()
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.

Channel

class kombu.transport.pyro.Channel(connection, **kwargs)[source]

Pyro Channel.

after_reply_message_received(queue)[source]

Callback called after RPC reply received.

Notes

Reply queue semantics: can be used to delete the queue after transient reply message received.

close()[source]

Close channel.

Cancel all consumers, and requeue unacked messages.

queues()[source]
shared_queues[source]