in mbp-with-mbo/src/main/java/com/epam/cme/mdp3/control/GapChannelController.java [56:78]
public GapChannelController(List<ChannelListener> channelListeners, ChannelController target, SnapshotRecoveryManager snapshotRecoveryManager,
IMDPOffHeapBuffer buffer, int gapThreshold, final int maxNumberOfTCPAttempts, String channelId, MdpMessageTypes mdpMessageTypes,
SnapshotCycleHandler mboCycleHandler, SnapshotCycleHandler mbpCycleHandler,
ScheduledExecutorService executor, TCPMessageRequester tcpMessageRequester,
List<Integer> mboIncrementMessageTemplateIds, List<Integer> mboSnapshotMessageTemplateIds) {
this.channelListeners = channelListeners;
this.buffer = buffer;
this.snapshotRecoveryManager = snapshotRecoveryManager;
this.target = target;
this.gapThreshold = gapThreshold;
this.maxNumberOfTCPAttempts = maxNumberOfTCPAttempts;
this.channelId = channelId;
this.mdpMessageTypes = mdpMessageTypes;
this.mboCycleHandler = mboCycleHandler;
this.mbpCycleHandler = mbpCycleHandler;
this.executor = executor;
if(tcpMessageRequester != null) {
TCPPacketListener tcpPacketListener = new TCPPacketListenerImpl();
this.tcpRecoveryProcessor = new TCPRecoveryProcessor(tcpMessageRequester, tcpPacketListener);
}
this.mboIncrementMessageTemplateIds = mboIncrementMessageTemplateIds;
this.mboSnapshotMessageTemplateIds = mboSnapshotMessageTemplateIds;
}