code: @Override
    public long getQueuedFlowSize() {
      long size = 0L;
      try {
        size = this.executorLoader.fetchQueuedFlows().size();
      } catch (final ExecutorManagerException e) {
        this.logger.error("Failed to get queued flow size.", e);
      }
      return size;
    }
docs: Get the number of non-dispatched flows from database. {@inheritDoc}