public void close()

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

• 26 lines of code
• 2 McCabe index (conditional complexity)

    public void close() {
        this.channelController.lock();
        try {
            this.channelController.switchState(ChannelState.CLOSING);
        } finally {
            this.channelController.unlock();
        }
        stopAllFeeds();
        try {
            closeFeed(incrementalFeedAThread, incrementalFeedA);
            closeFeed(incrementalFeedBThread, incrementalFeedB);
            closeFeed(snapshotFeedAThread, snapshotFeedA);
            closeFeed(snapshotFeedBThread, snapshotFeedB);
            closeFeed(instrumentFeedAThread, instrumentFeedA);
            closeFeed(instrumentFeedBThread, instrumentFeedB);
        } catch (Exception e) {
            logger.error("Failed to stop Feed Worker: " + e.getMessage(), e);
        }
        this.channelController.lock();
        try {
            channelController.close();
            this.channelController.switchState(ChannelState.CLOSED);
        } finally {
            this.channelController.unlock();
        }
    }