code: public static <K2, V2> ExportQueue<K2, V2> getInstance(String exportQueueId,
        SimpleConfiguration appConfig) {
      FluentConfigurator opts = FluentConfigurator.load(exportQueueId, appConfig);
      try {
        return new ExportQueue<>(opts, SimpleSerializer.getInstance(appConfig));
      } catch (Exception e) {
        // TODO
        throw new RuntimeException(e);
      }
    }
docs: TODO maybe add for stream and iterable