public IOTDeviceConsumerFromBlockingQueueToKinesisStreams()

in sample-kinesis-producer/src/main/java/com/optimize/downstream/samplekinesisproducer/IOTDeviceConsumerFromBlockingQueueToKinesisStreams.java [26:33]

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

    public IOTDeviceConsumerFromBlockingQueueToKinesisStreams(BlockingQueue<IOTDevice> inputQueue)
    {
        gson = new Gson();
        this.inputQueue = inputQueue;
        kinesis = new AmazonKinesisClient().withRegion(Regions.fromName(REGION));
        entries = new ArrayList();
        dataSize = 0;
    }