public void stopFeed()

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

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

    public void stopFeed(FeedType feedType, Feed feed){
        Map<FeedType, Pair<MdpFeedWorker, Thread>> currentFeed;
        if(Feed.A.equals(feed)){
            currentFeed = feedsA;
        } else if(Feed.B.equals(feed)){
            currentFeed = feedsB;
        } else {
            throw new IllegalArgumentException(String.format("%s feed is not supported", feed));
        }
        if(currentFeed.containsKey(feedType)){
            Pair<MdpFeedWorker, Thread> feedThread = currentFeed.get(feedType);
            MdpFeedWorker mdpFeedWorker = feedThread.getLeft();
            if(mdpFeedWorker.isActive()){
                mdpFeedWorker.shutdown();
            }
        }
    }