Node app polling elasticsearch backend and push to amqp for real time data.