private void handleMarketDataIncrementalRefresh()

in mbp-only/src/main/java/com/epam/cme/mdp3/core/control/ChannelController.java [133:150]

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

    private void handleMarketDataIncrementalRefresh(final MdpFeedContext feedContext, final MdpMessage mdpMessage, final long msgSeqNum, final short matchEventIndicator) {
        final MdpGroup incrGroup = feedContext.getMdpGroupObj();
        InstrumentController instController = null;
        mdpMessage.getGroup(MdConstants.NO_MD_ENTRIES, incrGroup);
        while (incrGroup.hashNext()) {
            incrGroup.next();
            final MDEntryType mdEntryType = MDEntryType.fromFIX(incrGroup.getChar(INCR_RFRSH_MD_ENTRY_TYPE));
            if (mdEntryType == MDEntryType.EmptyBook) {
                handleChannelReset(mdpMessage);
            } else {
                final int secId = incrGroup.getInt32(MdConstants.SECURITY_ID);
                if (instController == null || instController.getSecurityId() != secId) {
                    instController = channelContext.findInstrumentController(secId, null);
                }
                updateSecurityFromIncrementalRefresh(feedContext, msgSeqNum, matchEventIndicator, incrGroup, instController, secId);
            }
        }
    }