public static void main()

in resume-api/resume-api-aws2-kinesis/src/main/java/org/apache/camel/example/resume/aws/kinesis/main/MainApp.java [38:60]

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

    public static void main(String... args) {
        Main main = new Main();

        String streamName = System.getProperty("aws.kinesis.streamName", "aws-kinesis-test");

        String action = System.getProperty("resume.action");
        KinesisClient client = AWSSDKClientUtils.newKinesisClient();
        if ("load".equalsIgnoreCase(action)) {
            // do load
            loadData(client, streamName, 500);
            return;
        }

        Integer batchSize = Integer.parseInt(System.getProperty("batch.size", "50"));
        CountDownLatch latch = new CountDownLatch(batchSize);

        Executors.newSingleThreadExecutor().submit(() -> waitForStop(main, latch));

        RouteBuilder routeBuilder = new KinesisRoute(streamName, new CaffeineCache<>(100), client, latch);

        main.configure().addRoutesBuilder(routeBuilder);
        main.start();
    }