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')[source]

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)[source]

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

channel = None
connections(wait)[source]

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()[source]

start consuming rabbitmq messages

es_conn = None
es_host = None
es_port = 9200
queue_name = None
rmq_host = None
rmq_port = 5672
start()[source]

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')[source]

Bases: object

create mock method object

routing_key = None
vent.core.rmq_es_connector.test_rmq_es_connector.test_rmq_es_connector_callback()[source]

tests the callback function

vent.core.rmq_es_connector.test_rmq_es_connector.test_rmq_es_connector_connections()[source]

tests the connections function

vent.core.rmq_es_connector.test_rmq_es_connector.test_rmq_es_connector_start()[source]

tests the start function

Module contents