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)

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()

property shared_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…

driver_version()

global_state = <kombu.transport.virtual.base.BrokerState object>

property shared_queues

Channel

class kombu.transport.pyro.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()

property shared_queues

KombuBroker

class kombu.transport.pyro.KombuBroker

Kombu Broker used by the Pyro transport.

You have to run this as a separate (Pyro) service.