private RetrievalConfig getRetrievalConfig()

in src/main/java/com/googlesource/gerrit/plugins/kinesis/SchedulerProvider.java [72:85]

• 14 lines of code
• 2 McCabe index (conditional complexity)

  private RetrievalConfig getRetrievalConfig() {
    PollingConfig polling =
        new PollingConfig(streamName, kinesisAsyncClient)
            .idleTimeBetweenReadsInMillis(configuration.getPollingIntervalMs())
            .maxRecords(configuration.getMaxRecords());
    RetrievalConfig retrievalConfig =
        configsBuilder.retrievalConfig().retrievalSpecificConfig(polling);
    retrievalConfig.initialPositionInStreamExtended(
        InitialPositionInStreamExtended.newInitialPosition(
            fromBeginning
                ? InitialPositionInStream.TRIM_HORIZON
                : configuration.getInitialPosition()));
    return retrievalConfig;
  }