PipelineEventBookkeepingRouter
constructor(catalog: DestinationCatalog, syncManager: SyncManager, checkpointQueue: QueueWriter<Reserved<CheckpointMessageWrapped>>, openStreamQueue: QueueWriter<DestinationStream>, fileTransferQueue: MessageQueue<FileTransferQueueMessage>, @Named(value = "batchStateUpdateQueue") batchStateUpdateQueue: ChannelMessageQueue<BatchUpdate>, @Named(value = "numDataChannels") numDataChannels: Int, @Named(value = "markEndOfStreamAtEndOfSync") markEndOfStreamAtEndOfSync: Boolean, namespaceMapper: NamespaceMapper)