82
taskExecutors map[string]TaskExecutor,
83
taskExecutorProvider TaskExecutorProvider,
85
>
86
>
if taskExecutors == nil {
87
panic("Failed to initialize replication DLQ handler due to nil task executors")
88
}
90
>
shard: shard,
91
>
deleteManager: deleteManager,
92
>
workflowCache: workflowCache,
93
>
remoteHistoryFetcher: eventhandler.NewHistoryPaginatedFetcher(
94
>
shard.GetNamespaceRegistry(),
95
>
clientBean,
96
>
shard.GetPayloadSerializer(),
97
>
shard.GetLogger(),
98
>
),
99
>
taskExecutors: taskExecutors,
100
>
taskExecutorProvider: taskExecutorProvider,
101
>
logger: shard.GetLogger(),
102
>
}
103
}
104