Added amqp and elasticsearch bulk api encoder