public void handleSnapshotPacket()

in mbp-only/src/main/java/com/epam/cme/mdp3/core/control/ChannelController.java [224:240]

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

    public void handleSnapshotPacket(final MdpFeedContext feedContext, final MdpPacket mdpPacket) {
        lock.lock();
        try {
            final Iterator<MdpMessage> mdpMessageIterator = mdpPacket.iterator();
            while (mdpMessageIterator.hasNext()) {
                final MdpMessage mdpMessage = mdpMessageIterator.next();
                final MdpMessageType messageType = mdpMessageTypes.getMessageType(mdpMessage.getSchemaId());
                final SemanticMsgType msgType = messageType.getSemanticMsgType();
                if (msgType == SemanticMsgType.MarketDataSnapshotFullRefresh) {
                    mdpMessage.setMessageType(messageType);
                    handleSnapshotMessage(feedContext, mdpPacket.getMsgSeqNum(), mdpMessage);
                }
            }
        } finally {
            lock.unlock();
        }
    }