Parallelize message queue

fedify-dev · Sep 22, 2024 · ab2a1d1 · ab2a1d1
1 parent 1084bda
commit ab2a1d1
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/src/federation/index.ts b/src/federation/index.ts
@@ -14,6 +14,7 @@ import {
   Like,
   type MessageQueue,
   Note,
+  ParallelMessageQueue,
   PropertyValue,
   Question,
   Reject,
@@ -84,7 +85,10 @@ if (getRedisUrl() == null) {
   });
 }
 
-export const federation = createFederation({ kv, queue });
+export const federation = createFederation({
+  kv,
+  queue: new ParallelMessageQueue(queue, 10),
+});
 
 federation
   .setActorDispatcher("/@{handle}", async (ctx, handle) => {