Support exclusive Connection per listener

Author: amirmarmul

src/core/infrastructure/events/Listener.ts

@@ -12,9 +12,11 @@ export abstract class Listener<T> implements ListenerContract {
   protected extraQueues: any = {};
   abstract exchange: string;
   abstract topic: string;
+  protected exclusiveConnection: boolean = false;
 
+  // FIXME: support exclusive connection per listener
   constructor() {
-    this.connection = Connection.getConnection("listener");
+    this.connection = Connection.getConnection(this.connectionName);
   }
 
   init() {
@@ -61,6 +63,10 @@ export abstract class Listener<T> implements ListenerContract {
     return queue.join('.');
   }
 
+  get connectionName(): string {
+    return this.exclusiveConnection ? this.constructor.name : 'listener';
+  }
+
   protected parseMessage(msg: any) {
     const json = msg.content.toString();
     return JSON.parse(json);