protected void onAppMessage()

in fix/core/src/main/java/deltix/connector/fix/FixTradeConnector.java [325:350]

• 25 lines of code
• 7 McCabe index (conditional complexity)

    protected void onAppMessage(Header header, Message message) {
        if (nodeStatus != NodeStatus.LEADER) {
            return;
        }

        ByteSequence msgType = header.msgType();
        try {
            if (MsgType.EXECUTION_REPORT.equals(msgType)) {
                onExecutionReport(header, message);
            } else if (MsgType.ORDER_CANCEL_REJECT.equals(msgType)) {
                onCancelReject(header, message);
            } else if (MsgType.BUSINESS_MESSAGE_REJECT.equals(msgType)) {
                onBusinessReject(header, message);
            } else if (MsgType.NEWS.equals(msgType)) {
                onNews(header, message);
            } else {
                onCustomMessage(header, message);
            }
        } catch (final Throwable e) {
            LOG.warn("Connector %s can't handle app message with msg type: %s, msg seq num: %s. Error: %s")
                    .with(name)
                    .with(msgType)
                    .with(header.msgSeqNum())
                    .with(e);
        }
    }