summaryrefslogtreecommitdiff
path: root/src/queue/queues.ts
diff options
context:
space:
mode:
Diffstat (limited to 'src/queue/queues.ts')
-rw-r--r--src/queue/queues.ts7
1 files changed, 7 insertions, 0 deletions
diff --git a/src/queue/queues.ts b/src/queue/queues.ts
new file mode 100644
index 0000000000..d589d9f7da
--- /dev/null
+++ b/src/queue/queues.ts
@@ -0,0 +1,7 @@
+import config from '../config';
+import { initialize as initializeQueue } from './initialize';
+
+export const deliverQueue = initializeQueue('deliver', config.deliverJobPerSec || 128);
+export const inboxQueue = initializeQueue('inbox', config.inboxJobPerSec || 16);
+export const dbQueue = initializeQueue('db');
+export const objectStorageQueue = initializeQueue('objectStorage');