private static Properties getKafkaProperties()

in src/main/java/com/amazonaws/fixengineonaws/TestClient.java [378:408]

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

    private static Properties getKafkaProperties(String configfile) {
        LOGGER.fine("****GETTING KAFKA PROPERTIES 11: " + configfile);
        Properties kafkaprop = new Properties();  
            
        try {
        	FileReader reader = new FileReader(configfile);  
        	kafkaprop.load(reader);
       
        	
        	KAFKA_OUTBOUND_TOPIC_NAME = kafkaprop.getProperty("KafkaOutboundTopicName");;
        	KAFKA_INBOUND_TOPIC_NAME = kafkaprop.getProperty("KafkaInboundTopicName");
	        KAFKA_BROKER_STRING = kafkaprop.getProperty("KafkaBootstrapBrokerString");
	        
	        NO_OF_MESSAGES = Integer.parseInt(kafkaprop.getProperty("NoOfMessages"));
	        WAIT_BETWEEN_MESSAGES = Integer.parseInt(kafkaprop.getProperty("WaitBetweenMessages")) * 1000;
	        
	        SEND_EXEC_REPORT = Boolean.parseBoolean(kafkaprop.getProperty("SendExecReport")); 
		    
            
            LOGGER.info(" KAFKA_BROKER_STRING: " + KAFKA_BROKER_STRING);
            LOGGER.info(" SEND_EXEC_REPORT: " + SEND_EXEC_REPORT);
        	I_AM_TEST_CLIENT = kafkaprop.getProperty("ConnectionType").equals("initiator");
        	LOGGER.info(" I_AM_TEST_CLIENT: " + I_AM_TEST_CLIENT);
        	
        
		} catch (IOException e) {
			// TODO Auto-generated catch block
			 LOGGER.severe(e.getMessage());
		}
        return kafkaprop;
    }