public static void main()

in sample-kinesis-producer/src/main/java/com/optimize/downstream/entry/Main.java [15:40]

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

    public static void main(String [] args)
    {
        if(args.length !=1)
        {
            System.out.println("Needs an argument");
            System.out.println("Argument : Number of Messages to send to Kinesis");
            //System.out.println("2nd Argument : Number of Threads");
        }
        else {
            int numberOfSamplesInEachMessage = 2200; // Used 2200 to make the message size closer to 1 MB.
            // Will use one thread for simplicity.
            int numberOfThreads = 1; //Integer.parseInt(args[1]);
            int numberOfMessages = Integer.parseInt(args[0]);
            BlockingQueue<IOTDevice> inputQueue = new LinkedBlockingDeque();

            Thread[] consumerThread = new Thread[numberOfThreads];
            Thread producerThread = new Thread(new IOTDeviceProducerToBlockingQueue(inputQueue, numberOfMessages, numberOfSamplesInEachMessage));
            System.out.println("Starting producer and consumer.....");
            producerThread.start();

            for (int i = 0; i < numberOfThreads; i++) {
                consumerThread[i] = new Thread(new IOTDeviceConsumerFromBlockingQueueToKinesisStreams(inputQueue));
                consumerThread[i].start();
            }
        }
    }