public void onPacket()

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

• 21 lines of code
• 9 McCabe index (conditional complexity)

        public void onPacket(final MdpFeedContext feedContext, final MdpPacket mdpPacket) {
            final FeedType feedType = feedContext.getFeedType();
            final Feed feed = feedContext.getFeed();
            if (logger.isTraceEnabled()) {
                logger.trace("New MDP Packet: #{} from Feed {}:{}", mdpPacket.getMsgSeqNum(), feedType, feed);
            }
            for (ChannelListener mboChannelListener : listeners) {
                mboChannelListener.onPacket(getId(), feedType, feed, mdpPacket);
            }
            if (feedType == FeedType.N) {
                instrumentObserver.onPacket(feedContext, mdpPacket);
            } else if (feedType == FeedType.I) {
                if(incrementalStatistics != null && logger.isInfoEnabled()) {
                    incrementalStatistics.update(feed, mdpPacket.buffer().length());
                }
                lastIncrPcktReceived = System.currentTimeMillis();
                channelController.handleIncrementalPacket(feedContext, mdpPacket);
            } else if (feedType == FeedType.SMBO || feedType == FeedType.S) {
                channelController.handleSnapshotPacket(feedContext, mdpPacket);
            }
        }