ActiveMQ connector¶

`pymco.connector.activemq`¶

Contains ActiveMQ specific connector.

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

ActiveMQ 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()

send(msg, destination, *args, **kwargs)[source]¶

Re-implement pymco.connector.Connector.send()

This implementation adds extra features for ActiveMQ.