private void processOneInboundKafkaMessage()

in src/main/java/com/amazonaws/fixengineonaws/FixEngine.java [341:359]

• 18 lines of code
• 4 McCabe index (conditional complexity)

    private void processOneInboundKafkaMessage(ConsumerRecord<String, Object> kafkaMessage) {
        LOGGER.info(MY_IP+"****PROCESS ONE KAFKA MESSAGE: processing " + kafkaMessage.value().toString());
        if(DROP_KAFKA_MESSAGES) {
            LOGGER.severe(MY_IP+"****PROCESS ONE KAFKA MESSAGE: DROPPING MESSAGE INSTEAD OF SENDING IT!");        	
        } else {
	        Message parsedOrd = parseOrder(kafkaMessage.value().toString());
	        //[CLIENT FIX ENGINE] SEND ORDER FIX TO SERVER FIX ENGINE
	        try {
	        	LOGGER.info(MY_IP+"****PROCESS KAFKA MSGS: SENDING MESSAGE TO FIX: " + parsedOrd);
	            Session.sendToTarget(parsedOrd, FIX_SESSION_ID);
	        } catch (SessionNotFound se) {
	        	LOGGER.severe(MY_IP+"****PROCESS KAFKA MSGS: SessionNotFound: " + se);
	            se.printStackTrace();
	        } catch (Exception e) {
	        	LOGGER.severe(MY_IP+"****PROCESS KAFKA MSGS: Exception: " + e);
	            e.printStackTrace();
	        }
        }
    }