({
componentNodes,
telemetry,
cachePool,
appDataSource,
abortControllerPool,
usageCacheManager,
identityManager,
serverAdapter
}: {
componentNodes: IComponentNodes
telemetry: Telemetry
cachePool: CachePool
appDataSource: DataSource
abortControllerPool: AbortControllerPool
usageCacheManager: UsageCacheManager
identityManager: IdentityManager
serverAdapter?: ExpressAdapter
})
| 115 | } |
| 116 | |
| 117 | public setupAllQueues({ |
| 118 | componentNodes, |
| 119 | telemetry, |
| 120 | cachePool, |
| 121 | appDataSource, |
| 122 | abortControllerPool, |
| 123 | usageCacheManager, |
| 124 | identityManager, |
| 125 | serverAdapter |
| 126 | }: { |
| 127 | componentNodes: IComponentNodes |
| 128 | telemetry: Telemetry |
| 129 | cachePool: CachePool |
| 130 | appDataSource: DataSource |
| 131 | abortControllerPool: AbortControllerPool |
| 132 | usageCacheManager: UsageCacheManager |
| 133 | identityManager: IdentityManager |
| 134 | serverAdapter?: ExpressAdapter |
| 135 | }) { |
| 136 | const predictionQueueName = `${QUEUE_NAME}-prediction` |
| 137 | const predictionQueue = new PredictionQueue(predictionQueueName, this.connection, { |
| 138 | componentNodes, |
| 139 | telemetry, |
| 140 | cachePool, |
| 141 | appDataSource, |
| 142 | abortControllerPool, |
| 143 | usageCacheManager |
| 144 | }) |
| 145 | this.registerQueue('prediction', predictionQueue) |
| 146 | |
| 147 | this.predictionQueueEventsProducer = new QueueEventsProducer(predictionQueue.getQueueName(), { |
| 148 | connection: this.connection |
| 149 | }) |
| 150 | |
| 151 | const upsertionQueueName = `${QUEUE_NAME}-upsertion` |
| 152 | const upsertionQueue = new UpsertQueue(upsertionQueueName, this.connection, { |
| 153 | componentNodes, |
| 154 | telemetry, |
| 155 | cachePool, |
| 156 | appDataSource, |
| 157 | usageCacheManager |
| 158 | }) |
| 159 | this.registerQueue('upsert', upsertionQueue) |
| 160 | |
| 161 | const scheduleQueueName = `${QUEUE_NAME}-schedule` |
| 162 | const scheduleQueue = new ScheduleQueue(scheduleQueueName, this.connection, { |
| 163 | componentNodes, |
| 164 | telemetry, |
| 165 | cachePool, |
| 166 | appDataSource, |
| 167 | usageCacheManager, |
| 168 | identityManager |
| 169 | }) |
| 170 | this.registerQueue('schedule', scheduleQueue) |
| 171 | |
| 172 | if (serverAdapter) { |
| 173 | createBullBoard({ |
| 174 | queues: [ |
no test coverage detected