bulk-cdk-toolkit-load-db/io.airbyte.cdk.load.pipeline.db/BulkLoadCompletedUploadQueue/bulkLoadCompletedUploadQueue

bulkLoadCompletedUploadQueue

@Singleton
@Secondary
@Requires(bean = BulkLoaderFactory::class)
@Named(value = "objectLoaderCompletedUploadQueue")
fun bulkLoadCompletedUploadQueue(bulkLoader: BulkLoaderFactory<K, T>): PartitionedQueue<PipelineEvent<K, ObjectLoaderUploadCompleter.UploadResult<T>>>