kombu.transport.pyro
Pyro transport.
Requires the Pyro4 library to be installed.
-
class kombu.transport.pyro.Transport(client, **kwargs)
-
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()
-
Transport.shared_queues
-
Transport.state = <kombu.transport.virtual.BrokerState object at 0x2b35eadb63d0>
memory backend state is global.
-
class kombu.transport.pyro.Channel(connection, **kwargs)
-
after_reply_message_received(queue)
-
queues()
-
shared_queues