protected void onNextPoint()

in java/ws-server/src/main/java/com/epam/deltix/tbwg/webapp/services/charting/transformations/FeedStatusTransformation.java [44:76]

32 lines of code
7 McCabe index (conditional complexity)


    protected void onNextPoint(MarketMessageInfo marketMessage) {
        if (marketMessage instanceof SecurityStatusMessage) {
            SecurityStatusMessage statusMessage = (SecurityStatusMessage) marketMessage;
            if (statusMessage.getStatus() == SecurityStatus.FEED_DISCONNECTED) {
                disconnected = true;
                sendMessage(
                    new FeedStatusMessage(statusMessage.getTimeStampMs(), statusMessage.getExchangeId(), FeedStatus.NOT_AVAILABLE)
                );
            } else if (statusMessage.getStatus() == SecurityStatus.FEED_CONNECTED) {
                disconnected = false;
                sendMessage(
                    new FeedStatusMessage(statusMessage.getTimeStampMs(), statusMessage.getExchangeId(), FeedStatus.AVAILABLE)
                );
            }
        } else if (marketMessage instanceof SecurityFeedStatusMessage) {
            SecurityFeedStatusMessage statusMessage = (SecurityFeedStatusMessage) marketMessage;
            if (statusMessage.getStatus() == FeedStatus.NOT_AVAILABLE) {
                disconnected = true;
                sendMessage(
                    new FeedStatusMessage(statusMessage.getTimeStampMs(), statusMessage.getExchangeId(), FeedStatus.NOT_AVAILABLE)
                );
            } else {
                disconnected = false;
                sendMessage(
                    new FeedStatusMessage(statusMessage.getTimeStampMs(), statusMessage.getExchangeId(), FeedStatus.AVAILABLE)
                );
            }
        }

        if (!disconnected) {
            sendMessage(marketMessage);
        }
    }