public static void main()

in src/main/java/com/amazonaws/fixengineonaws/TestClient.java [142:189]
23 lines of code
4 McCabe index (conditional complexity)

    public static void main(String[] args) throws ConfigError, FileNotFoundException, InterruptedException, SessionNotFound {

        LOGGER.setLevel(Level.INFO);
        //LOGGER.setLevel(Level.WARNING);
        
        String configfile = "config/server.cfg";
    	if(args.length > 0) {
    		configfile = args[0];
    	} 
		LOGGER.info("***MAIN STARTING WITH CONFIG FILE: " + configfile);

        // setup kafka producer and consumefr
        setupKafka(configfile);
        
        Thread a1 = new Thread(() -> {
            LOGGER.info("***processKafkaMsgs Thread strated ****** ");
            LOGGER.info("**SEND_EXEC_REPORT 11 : " + SEND_EXEC_REPORT);
            //if (!I_AM_TEST_CLIENT && SEND_EXEC_REPORT) {
            if (!I_AM_TEST_CLIENT) processKafkaMsgs();
            LOGGER.info("***processKafkaMsgs Thread Ends******************************************************************************** ****** ");
        });
        
        a1.start();
       
            
        generateOrders();
        
        
        try { 
            a1.join(); 
        } 
        catch (Exception e) { 
            System.out.println(e); 
        }
        
        // 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: " + startdate + 
        //             "\n End Time: " + lastOrderGeneratedTime + "\n Total Messages Processed: " + NO_OF_MESSAGES 
        //             + "\n Total Processing Time (seconds) " + totalTimeInSec + "\n TPS: " + tps);
        	
        // LOGGER.info(" ************ ************ ************ ************ ************");	
    }