fix(bus): check for event handler existence (#39)

fixes #19
NeuraLegion · Apr 18, 2022 · 52db41e · 52db41e
1 parent 28f49e9
commit 52db41e
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/packages/bus/src/dispatchers/RMQEventBus.ts b/packages/bus/src/dispatchers/RMQEventBus.ts
@@ -237,11 +237,13 @@ export class RMQEventBus implements EventBus {
   private resolveHandler<T, R>(
     type: EventHandlerConstructor<T, R>
   ): EventHandler<T, R> {
-    if (!this.container.isRegistered(type)) {
+    const eventHandler = this.container.resolve(type);
+
+    if (!eventHandler) {
       throw new EventHandlerNotFound(type.name);
     }
 
-    return this.container.resolve(type);
+    return eventHandler;
   }
 
   private async expectReply<R>(