private void checkFeedIdleState()

in mbp-with-mbo/src/main/java/com/epam/cme/mdp3/channel/LowLevelMdpChannel.java [273:287]

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

    private void checkFeedIdleState() {
        try {
            synchronized (this) {
                MdpFeedWorker incrementalFeedA = feedsA.get(FeedType.I).getLeft();
                MdpFeedWorker incrementalFeedB = feedsB.get(FeedType.I).getLeft();
                final long allowedInactiveEndTime = lastIncrPcktReceived + idleWindowInMillis;
                if (allowedInactiveEndTime < System.currentTimeMillis() &&
                        (incrementalFeedA.isActiveAndNotShutdown() || incrementalFeedB.isActiveAndNotShutdown())) {
                    recoveryManager.startRecovery();
                }
            }
        } catch (Exception e){
            logger.error(e.getMessage(), e);
        }
    }