RabbitMQ connector

pymco.connector.rabbitmq

RabbitMQ specific connector plugin.

class pymco.connector.rabbitmq.RabbitMQConnector(config, connection=None, logger=<logging.Logger object>)[source]

RabbitMQ middleware specific connector.

get_reply_target(agent, collective)[source]

Implement pymco.connector.Connector.get_reply_target()

get_target(agent, collective)[source]

Implement pymco.connector.Connector.get_target()