1
1
/* globals Promise */
2
2
import _ from 'lodash' ;
3
3
import amqplib from 'amqplib' ;
4
- import { EventEmitter } from 'events' ;
5
- import { handlers as msgHandlers } from '../events' ;
4
+ import handlers from '../events' ;
6
5
7
- module . exports = class RabbitMQService extends EventEmitter {
6
+ module . exports = class RabbitMQService {
8
7
9
8
/**
10
9
* constructor
11
10
* @param {Object } app express app Object
12
11
* @param {Object } logger logger object
13
12
*/
14
13
constructor ( app , logger ) {
15
- super ( ) ;
16
- EventEmitter . call ( this ) ;
17
14
this . app = app ;
18
15
this . logger = logger ;
19
16
this . subscriberCxn = null ;
@@ -87,7 +84,7 @@ module.exports = class RabbitMQService extends EventEmitter {
87
84
self . subscriberQ = qok . queue ;
88
85
// bindings for the queue
89
86
// all these keys/bindings should be routed to the same queue
90
- const bindings = _ . keys ( msgHandlers ) ;
87
+ const bindings = _ . keys ( handlers ) ;
91
88
self . logger . debug ( 'Adding bindings: ' , bindings ) ;
92
89
const bindingPromises = _ . map ( bindings , rk =>
93
90
channel . bindQueue ( self . subscriberQ , self . exchangeName , rk ) ) ;
@@ -101,7 +98,7 @@ module.exports = class RabbitMQService extends EventEmitter {
101
98
requestId : msg . properties . correlationId ,
102
99
} ) ;
103
100
cLogger . debug ( 'Received Message' , key , msg . fields ) ;
104
- const handler = msgHandlers [ key ] ;
101
+ const handler = handlers [ key ] ;
105
102
if ( ! _ . isFunction ( handler ) ) {
106
103
cLogger . error ( `Unknown message type: ${ key } , NACKing... ` ) ;
107
104
// channel.nack(msg, false, false)
0 commit comments