Mike Gerwitz

Activist for User Freedom

aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
Diffstat (limited to 'src/system/amqp/AmqpConnection.ts')
-rw-r--r--src/system/amqp/AmqpConnection.ts5
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();
} );