Сollects data from amqp and sends to elasticsearch bulk API