public void startSnapshotFeedB()

in mbp-only/src/main/java/com/epam/cme/mdp3/core/channel/MdpChannelImpl.java [348:363]

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

    public void startSnapshotFeedB() throws MdpFeedException {
        if (snapshotFeedB == null) {
            synchronized (this) {
                if (snapshotFeedB == null) {
                    snapshotFeedB = new MdpFeedWorker(channelCfg.getConnectionCfg(FeedType.S, Feed.B), snapshotFeedBni, rcvBufSize);
                    snapshotFeedB.addListener(this.mdpFeedListener);
                }
            }
        }
        if (!snapshotFeedB.cancelShutdownIfStarted()) {
            if (!snapshotFeedB.isActive()) {
                snapshotFeedBThread = new Thread(snapshotFeedB);
                snapshotFeedBThread.start();
            }
        }
    }