This document is for Kombu's development version, which can be significantly different from previous releases. Get the stable docs here: 3.0.

Pyro Transport - kombu.transport.pyro

Pyro transport.

Requires the Pyro4 library to be installed.

Transport

class kombu.transport.pyro.Transport(client, **kwargs)

Pyro Transport.

class Channel(connection, **kwargs)

Pyro Channel.

after_reply_message_received(queue)

queues()

shared_queues

Transport.default_port = 9090

Transport.driver_name = u'pyro'

Transport.driver_type = u'pyro'

Transport.driver_version()

Transport.shared_queues

Transport.state = <kombu.transport.virtual.base.BrokerState object>

memory backend state is global.

Channel

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

Pyro Channel.

after_reply_message_received(queue)

queues()

shared_queues