Add elasticsearch_query to logstash agent so we can use elasticsearch_river