private void handleIncrementalQueue()

in mbp-only/src/main/java/com/epam/cme/mdp3/core/control/InstrumentController.java [135:155]

20 lines of code
6 McCabe index (conditional complexity)


    private void handleIncrementalQueue(final MdpFeedContext feedContext, final long prcdSeqNum) {
        if(logger.isDebugEnabled()) {
            logger.debug("Feed {}:{} | handleIncrementalQueue: after {}",
                    feedContext.getFeedType(), feedContext.getFeed(), prcdSeqNum);
        }
        final IncrementalRefreshQueue queue = this.incrRefreshQueue;

        for (long i = prcdSeqNum + 1; i <= queue.getLastRptSeqNum(); i++) {
            if (queue.poll(i, this.incrQueueEntry) > 0) {
                if(logger.isTraceEnabled()) {
                    logger.trace("Feed {}:{} | Process incremental entry #{} from queue",
                            feedContext.getFeedType(), feedContext.getFeed(), i);
                }
                if (!handleSecurityRefreshInQueue(this.incrQueueEntry)) {
                    return;
                }
            } else {
                return;
            }
        }
    }