public void run()

in src/main/java/com/amazonaws/kinesisvideo/parser/kinesis/KinesisDataStreamsWorker.java [53:86]

• 30 lines of code
• 3 McCabe index (conditional complexity)

    public void run() {

        try {
            String workerId = InetAddress.getLocalHost().getCanonicalHostName() + ":" + UUID.randomUUID();
            KinesisClientLibConfiguration kinesisClientLibConfiguration =
                    new KinesisClientLibConfiguration(APPLICATION_NAME,
                            kdsStreamName,
                            credentialsProvider,
                            workerId);
            kinesisClientLibConfiguration.withInitialPositionInStream(SAMPLE_APPLICATION_INITIAL_POSITION_IN_STREAM)
                    .withRegionName(region.getName());

            final IRecordProcessorFactory recordProcessorFactory =
                    () -> new KinesisRecordProcessor(rekognizedFragmentsIndex, credentialsProvider);
            final Worker worker = new Worker(recordProcessorFactory, kinesisClientLibConfiguration);

            System.out.printf("Running %s to process stream %s as worker %s...",
                    APPLICATION_NAME,
                    kdsStreamName,
                    workerId);

            int exitCode = 0;
            try {
                worker.run();
            } catch (Throwable t) {
                System.err.println("Caught throwable while processing data.");
                t.printStackTrace();
                exitCode = 1;
            }
            System.out.println("Exit code : " + exitCode);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }