private static void generateOrders()

in src/main/java/com/amazonaws/fixengineonaws/TestClient.java [212:267]
31 lines of code
5 McCabe index (conditional complexity)

    private static void generateOrders() throws InterruptedException{
        
        Date startdate = new Date();
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS");
        if (I_AM_TEST_CLIENT) {
            
            
            LOGGER.info(" NO_OF_MESSAGES : " + NO_OF_MESSAGES + "  WAIT_BETWEEN_MESSAGES: " + WAIT_BETWEEN_MESSAGES);
            
            //for(int orderId=1;orderId<1000;orderId++) {
            for(int orderId=1;orderId<=NO_OF_MESSAGES;orderId++) {
                String ordStr = null;
                
                Thread.sleep(WAIT_BETWEEN_MESSAGES);
                // [CLIENT LAMBDA] CREATE NEW ORDER:
               	LOGGER.info("***main() I_AM_TEST_CLIENT " + I_AM_TEST_CLIENT + " orderId # " + orderId);
                //if (I_AM_TEST_CLIENT) {
                    
                    NewOrderSingle ord = generateOrder(orderId);
                    ordStr = ord.toString();
                
            		 LOGGER.info("*********** ORDER Client to Server *****************************************************************************************");
            		 LOGGER.info("************GENERATED ORDER FIX STRING: " + ordStr);
            		 //LOGGER.info("****************************************************************************************************");
            		
            		// Pick a sentence at random
                    //String sentence = "testing from fix server";
                    // Send the sentence to the test topic
                    try
                    {
                        KAFKA_PRODUCER.send(new ProducerRecord<String, String>(KAFKA_OUTBOUND_TOPIC_NAME, ordStr)).get();
                        //producer.send(new ProducerRecord<String, String>(topicName, message.toString())).get();
                    } catch (Exception ex) {
                        LOGGER.severe(ex.getMessage());
                    }
    
                //} // I_AM_TEST_CLIENT
            }
            lastOrderGeneratedTime = new Date();
            
            
            long totalTimeInSec = (lastOrderGeneratedTime.getTime() - startdate.getTime())/1000;
        
            if (totalTimeInSec < 1) totalTimeInSec = 1;
            
            double tps = NO_OF_MESSAGES/totalTimeInSec;
            
            LOGGER.info(" ************ Order Generation Performance & Througput Results ******************* ");
            LOGGER.info("\n Start Time: " + sdf.format(startdate) + 
                        "\n End Time: " + sdf.format(lastOrderGeneratedTime) + "\n Total Messages Processed: " + NO_OF_MESSAGES 
                        + "\n Total Processing Time (seconds) " + totalTimeInSec + "\n TPS: " + tps);
            	
            LOGGER.info(" ************ ************ ************ ************ ************");
        }
        
    }