diff options
| author | syuilo <Syuilotan@yahoo.co.jp> | 2022-09-19 03:00:25 +0900 |
|---|---|---|
| committer | syuilo <Syuilotan@yahoo.co.jp> | 2022-09-19 03:00:25 +0900 |
| commit | 6c5a42e745574c8b57dd48d5b1e2c0b28df086ca (patch) | |
| tree | b972e6ff62110a1b3bff664bac79945f2ab0e185 /packages/backend/src/queue/QueueProcessorService.ts | |
| parent | fix (diff) | |
| download | sharkey-6c5a42e745574c8b57dd48d5b1e2c0b28df086ca.tar.gz sharkey-6c5a42e745574c8b57dd48d5b1e2c0b28df086ca.tar.bz2 sharkey-6c5a42e745574c8b57dd48d5b1e2c0b28df086ca.zip | |
fix queue bug
Diffstat (limited to 'packages/backend/src/queue/QueueProcessorService.ts')
| -rw-r--r-- | packages/backend/src/queue/QueueProcessorService.ts | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/packages/backend/src/queue/QueueProcessorService.ts b/packages/backend/src/queue/QueueProcessorService.ts index 27afce0824..7be0f7b469 100644 --- a/packages/backend/src/queue/QueueProcessorService.ts +++ b/packages/backend/src/queue/QueueProcessorService.ts @@ -99,10 +99,10 @@ export class QueueProcessorService { .on('error', (job: any, err: Error) => webhookLogger.error(`error ${err}`, { job, e: renderError(err) })) .on('stalled', (job) => webhookLogger.warn(`stalled ${getJobInfo(job)} to=${job.data.to}`)); - this.queueService.deliverQueue.process(this.config.deliverJobConcurrency ?? 128, (job, done) => this.deliverProcessorService.process(job)); - this.queueService.inboxQueue.process(this.config.inboxJobConcurrency ?? 16, (job, done) => this.inboxProcessorService.process(job)); + this.queueService.deliverQueue.process(this.config.deliverJobConcurrency ?? 128, (job) => this.deliverProcessorService.process(job)); + this.queueService.inboxQueue.process(this.config.inboxJobConcurrency ?? 16, (job) => this.inboxProcessorService.process(job)); this.queueService.endedPollNotificationQueue.process((job, done) => this.endedPollNotificationProcessorService.process(job, done)); - this.queueService.webhookDeliverQueue.process(64, (job, done) => this.webhookDeliverProcessorService.process(job)); + this.queueService.webhookDeliverQueue.process(64, (job) => this.webhookDeliverProcessorService.process(job)); this.dbQueueProcessorsService.start(this.queueService.dbQueue); this.objectStorageQueueProcessorsService.start(this.queueService.objectStorageQueue); |