fix: increase thread pool size (#85)

closes #83
NeuraLegion · Aug 30, 2020 · bd64ad7 · bd64ad7
1 parent 7d7632e
commit bd64ad7
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 1 deletion.
diff --git a/src/Bus/Brokers/RabbitMQBus.ts b/src/Bus/Brokers/RabbitMQBus.ts
@@ -228,13 +228,19 @@ export class RabbitMQBus implements Bus {
 
         // eslint-disable-next-line max-depth
         if (response) {
-          this.channel.sendToQueue(
+          const sendResult: boolean = this.channel.sendToQueue(
             replyTo,
             Buffer.from(JSON.stringify(response)),
             {
               correlationId
             }
           );
+
+          // eslint-disable-next-line max-depth
+          if (!sendResult) {
+            console.log(sendResult);
+            await new Promise((resolve) => this.channel.once('drain', resolve));
+          }
         }
       }
     } catch (err) {

diff --git a/src/index.ts b/src/index.ts
@@ -1,3 +1,4 @@
+process.env.UV_THREADPOOL_SIZE = String(1024);
 import 'reflect-metadata';
 import {
   GenerateArchive,