code: private void doBatchEnd(final JsonObject message) {
      if (currentBatch != null) {
        Object args = deserializer.deserialize(message);
        if (log.isDebugEnabled()) {
          log.debug(String.format("%s - Batch ended: Batch[batch=%s, args=%s]", this, currentBatch.id(), args));
        }
        currentBatch.handleEnd(args);
        currentBatch = null;
      }
    }
docs: Handles a batch end.