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

# Pyro Transport - `kombu.transport.pyro`

Pyro transport module for kombu.

Pyro transport, and Kombu Broker daemon.

Requires the `Pyro5` 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.