An ActiveMQ River implementation for ElasticSearch