SchedulerProvider create()

in src/main/java/com/googlesource/gerrit/plugins/kinesis/SchedulerProvider.java [35:56]

• 20 lines of code
• 1 McCabe index (conditional complexity)

    SchedulerProvider create(
        String streamName,
        boolean fromBeginning,
        java.util.function.Consumer<Event> messageProcessor);
  }

  private final ConfigsBuilder configsBuilder;
  private final Configuration configuration;
  private final KinesisAsyncClient kinesisAsyncClient;
  private final String streamName;
  private final boolean fromBeginning;

  @AssistedInject
  SchedulerProvider(
      Configuration configuration,
      KinesisAsyncClient kinesisAsyncClient,
      DynamoDbAsyncClient dynamoDbAsyncClient,
      CloudWatchAsyncClient cloudWatchAsyncClient,
      KinesisRecordProcessorFactory.Factory kinesisRecordProcessorFactory,
      @Assisted String streamName,
      @Assisted boolean fromBeginning,
      @Assisted java.util.function.Consumer<Event> messageProcessor) {