diff options
Diffstat (limited to 'src/system/amqp/AmqpConnection.ts')
| -rw-r--r-- | src/system/amqp/AmqpConnection.ts | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/src/system/amqp/AmqpConnection.ts b/src/system/amqp/AmqpConnection.ts index 6d50bfc..410f808 100644 --- a/src/system/amqp/AmqpConnection.ts +++ b/src/system/amqp/AmqpConnection.ts @@ -24,8 +24,6 @@ import * as amqplib from "amqplib"; /** * Connection to AMQP exchange - * - * XXX: Needs tests! */ export class AmqpConnection { @@ -39,6 +37,7 @@ export class AmqpConnection /** * Amqp Connection * + * @param _conf - amqp library * @param _conf - amqp configuration * @param _emitter - event emitter instance */ @@ -65,7 +64,7 @@ export class AmqpConnection */ this._conn.once( 'error', e => { - this._emitter.emit( 'amqp-conn-error', e ); + this._emitter.emit( 'amqp-conn-warn', e ); this._reconnect(); } ); |