kombu.transport.pyro

Pyro transport.

Requires the Pyro4 library to be installed.

Transport

class kombu.transport.pyro.Transport(client, **kwargs)[source]
class Channel(connection, **kwargs)
after_reply_message_received(queue)
queues()
shared_queues
Transport.default_port = 9090
Transport.driver_name = 'pyro'
Transport.driver_type = 'pyro'
Transport.driver_version()[source]
Transport.shared_queues[source]
Transport.state = <kombu.transport.virtual.BrokerState object>

memory backend state is global.

Channel

class kombu.transport.pyro.Channel(connection, **kwargs)[source]
after_reply_message_received(queue)[source]
queues()[source]
shared_queues[source]