public void run()

in mbp-with-mbo/src/main/java/com/epam/cme/mdp3/control/GapChannelController.java [287:305]


        public void run() {
            try {
                boolean result = tcpMessageRequester.askForLostMessages(beginSeqNo, endSeqNo, tcpPacketListener);
                if (result) {
                    try {
                        lock.lock();
                        switchState(ChannelState.SYNC);
                        processMessagesFromBuffer(feedContext);
                        numberOfTCPAttempts = 0;
                    } finally {
                        lock.unlock();
                    }
                } else {
                    snapshotRecoveryManager.startRecovery();
                }
            } catch (Exception e) {
                log.error(e.getMessage(), e);
            }
        }