public void handleIncrementalPacket()

in mbp-with-mbo/src/main/java/com/epam/cme/mdp3/control/ChannelControllerRouter.java [86:110]

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

    public void handleIncrementalPacket(MdpFeedContext feedContext, MdpPacket mdpPacket) {
        MdpGroup mdpGroup = feedContext.getMdpGroupObj();
        MdpGroupEntry mdpGroupEntry = feedContext.getMdpGroupEntryObj();
        long msgSeqNum = mdpPacket.getMsgSeqNum();
        for (MdpMessage mdpMessage : mdpPacket) {
            updateSemanticMsgType(mdpMessageTypes, mdpMessage);
            SemanticMsgType semanticMsgType = mdpMessage.getSemanticMsgType();
            switch (semanticMsgType) {
                case MarketDataIncrementalRefresh:
                    handleIncrementalMessage(mdpMessage, mdpGroup, mdpGroupEntry, msgSeqNum);
                    break;
                case QuoteRequest:
                    handleQuoteRequest(mdpMessage);
                    break;
                case SecurityStatus:
                    handleSecurityStatus(mdpMessage);
                    break;
                case SecurityDefinition:
                    instrumentObserver.onMessage(feedContext, mdpMessage);
                    break;
                default:
                    logger.debug("Message has been ignored due to its SemanticMsgType '{}'", semanticMsgType);
            }
        }
    }