class ESPushTask extends BaseTask {

    protected OutgoingMessageEnvelope getAvroKeyOutMsg(IncomingMessageEnvelope envelope, ESPushTaskConfig.ESIndexSpec spec) {
        return getAvroKeyOutMsg(envelope, spec, Optional.empty());
    }

}