Class Consumer

src/Adapters/MessageQueue/EventEmitterMQ.js:28–48

}

class Consumer extends events.EventEmitter {
  emitter: any;

  constructor(emitter: any) {
    super();
    this.emitter = emitter;
  }

  subscribe(channel: string): void {
    unsubscribe(channel);
    const handler = message => {
      this.emit('message', channel, message);
    };
    subscriptions.set(channel, handler);
    this.emitter.on(channel, handler);
  }

  unsubscribe(channel: string): void {
    unsubscribe(channel);
  }
}

function createPublisher(): any {
  return new Publisher(emitter);