summaryrefslogtreecommitdiff
path: root/packages/backend/src/queue/queues.ts
diff options
context:
space:
mode:
authorsyuilo <Syuilotan@yahoo.co.jp>2022-03-06 16:06:27 +0900
committersyuilo <Syuilotan@yahoo.co.jp>2022-03-06 16:06:27 +0900
commit2442592ef1a51cad901cf5e7fe30cdc85d7568cc (patch)
tree668e11d1d94b023a3fcd49a5daba8c0d96b7fd71 /packages/backend/src/queue/queues.ts
parentUpdate CHANGELOG.md (diff)
downloadsharkey-2442592ef1a51cad901cf5e7fe30cdc85d7568cc.tar.gz
sharkey-2442592ef1a51cad901cf5e7fe30cdc85d7568cc.tar.bz2
sharkey-2442592ef1a51cad901cf5e7fe30cdc85d7568cc.zip
feat: アンケート終了通知
Resolve #4664
Diffstat (limited to 'packages/backend/src/queue/queues.ts')
-rw-r--r--packages/backend/src/queue/queues.ts3
1 files changed, 2 insertions, 1 deletions
diff --git a/packages/backend/src/queue/queues.ts b/packages/backend/src/queue/queues.ts
index 6ac4ec69cf..02df587365 100644
--- a/packages/backend/src/queue/queues.ts
+++ b/packages/backend/src/queue/queues.ts
@@ -1,8 +1,9 @@
import config from '@/config/index.js';
import { initialize as initializeQueue } from './initialize.js';
-import { DeliverJobData, InboxJobData, DbJobData, ObjectStorageJobData } from './types.js';
+import { DeliverJobData, InboxJobData, DbJobData, ObjectStorageJobData, EndedPollNotificationJobData } from './types.js';
export const systemQueue = initializeQueue<Record<string, unknown>>('system');
+export const endedPollNotificationQueue = initializeQueue<EndedPollNotificationJobData>('endedPollNotification');
export const deliverQueue = initializeQueue<DeliverJobData>('deliver', config.deliverJobPerSec || 128);
export const inboxQueue = initializeQueue<InboxJobData>('inbox', config.inboxJobPerSec || 16);
export const dbQueue = initializeQueue<DbJobData>('db');