fix(core): awaiting queuing of the messages

botpress · Mar 2, 2019 · fb153e9 · fb153e9
1 parent b159ad5
commit fb153e9
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/bp/core/services/middleware/event-engine.ts b/src/bp/core/services/middleware/event-engine.ts
@@ -119,10 +119,10 @@ export class EventEngine {
 
     if (event.direction === 'incoming') {
       incrementMetric('eventsIn.count')
-      this.incomingQueue.enqueue(event, 1, false)
+      await this.incomingQueue.enqueue(event, 1, false)
     } else {
       incrementMetric('eventsOut.count')
-      this.outgoingQueue.enqueue(event, 1, false)
+      await this.outgoingQueue.enqueue(event, 1, false)
     }
   }