summaryrefslogtreecommitdiff
path: root/packages/backend/src/core/QueueModule.ts
diff options
context:
space:
mode:
authorsyuilo <Syuilotan@yahoo.co.jp>2023-04-07 11:27:01 +0900
committersyuilo <Syuilotan@yahoo.co.jp>2023-04-07 11:27:01 +0900
commit239d3f2dbfb602c20a8bcc89b0be2eeedcc6f3ae (patch)
treee81ae7fdb9318a18b2c8794c4bd341ef9d39bf14 /packages/backend/src/core/QueueModule.ts
parentfeat(backend): イベント用Redisを別サーバーに分離できるように (diff)
downloadsharkey-239d3f2dbfb602c20a8bcc89b0be2eeedcc6f3ae.tar.gz
sharkey-239d3f2dbfb602c20a8bcc89b0be2eeedcc6f3ae.tar.bz2
sharkey-239d3f2dbfb602c20a8bcc89b0be2eeedcc6f3ae.zip
feat(backend): ジョブキュー用Redisを別サーバーに分離できるように
Diffstat (limited to 'packages/backend/src/core/QueueModule.ts')
-rw-r--r--packages/backend/src/core/QueueModule.ts12
1 files changed, 6 insertions, 6 deletions
diff --git a/packages/backend/src/core/QueueModule.ts b/packages/backend/src/core/QueueModule.ts
index edd843977b..8733a7d7eb 100644
--- a/packages/backend/src/core/QueueModule.ts
+++ b/packages/backend/src/core/QueueModule.ts
@@ -8,13 +8,13 @@ import type { DeliverJobData, InboxJobData, DbJobData, ObjectStorageJobData, End
function q<T>(config: Config, name: string, limitPerSec = -1) {
return new Bull<T>(name, {
redis: {
- port: config.redis.port,
- host: config.redis.host,
- family: config.redis.family == null ? 0 : config.redis.family,
- password: config.redis.pass,
- db: config.redis.db ?? 0,
+ port: config.redisForJobQueue.port,
+ host: config.redisForJobQueue.host,
+ family: config.redisForJobQueue.family == null ? 0 : config.redisForJobQueue.family,
+ password: config.redisForJobQueue.pass,
+ db: config.redisForJobQueue.db ?? 0,
},
- prefix: config.redis.prefix ? `${config.redis.prefix}:queue` : 'queue',
+ prefix: config.redisForJobQueue.prefix ? `${config.redisForJobQueue.prefix}:queue` : 'queue',
limiter: limitPerSec > 0 ? {
max: limitPerSec,
duration: 1000,