public GapChannelController()

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;
    }