in mbp-with-mbo/src/main/java/com/epam/cme/mdp3/channel/LowLevelMdpChannel.java [308:323]
private void closeFeed(Pair<MdpFeedWorker, Thread> feedThread){
try {
Thread thread = feedThread.getRight();
MdpFeedWorker feedWorker = feedThread.getLeft();
if (thread.isAlive()) {
try {
thread.join(1000);
} catch (InterruptedException e) {
logger.error("Timed out waiting to stop Feed Worker: " + e.getMessage(), e);
}
feedWorker.close();
}
} catch (Exception e) {
logger.error("Failed to stop Feed Worker: " + e.getMessage(), e);
}
}