vent.core.rmq_es_connector package

Submodules

vent.core.rmq_es_connector.rmq_es_connector module

class vent.core.rmq_es_connector.rmq_es_connector.RmqEs(es_host='elasticsearch', rmq_host='rabbitmq')

Bases: object

opens a connection to rabbitmq and receives messages based on the provided binding keys and then takes those messages and sends them to an elasticsearch index

callback(ch, method, properties, body)

callback triggered on rabiitmq message received and sends it to an elasticsearch index

channel = None

connections(wait)

wait for connections to both rabbitmq and elasticsearch to be made before binding a routing key to a channel and sending messages to elasticsearch

consume()

start consuming rabbitmq messages

es_conn = None

es_host = None

es_port = 9200

queue_name = None

rmq_host = None

rmq_port = 5672

start()

start the channel listener and start consuming messages

vent.core.rmq_es_connector.test_rmq_es_connector module

class vent.core.rmq_es_connector.test_rmq_es_connector.Method(routing_key='foo.bar')

Bases: object

create mock method object

routing_key = None

vent.core.rmq_es_connector.test_rmq_es_connector.test_rmq_es_connector_callback()

tests the callback function

vent.core.rmq_es_connector.test_rmq_es_connector.test_rmq_es_connector_connections()

tests the connections function

vent.core.rmq_es_connector.test_rmq_es_connector.test_rmq_es_connector_start()

tests the start function

Module contents