feat(connection-errors): add some connection-related errors

noodlefrenzy · Jun 18, 2015 · f465c3e · f465c3e
1 parent 47bdd54
commit f465c3e
Showing 1 changed file with 26 additions and 0 deletions.
diff --git a/lib/errors.js b/lib/errors.js
@@ -124,3 +124,29 @@ errors.InvalidStateError = function(msg) {
   this.name = 'AmqpInvalidStateError';
 };
 util.inherits(errors.InvalidStateError, errors.BaseError);
+
+/**
+ * Connection error
+ *
+ * @param msg
+ * @extends BaseError
+ * @constructor
+ */
+errors.ConnectionError = function(msg) {
+  errors.BaseError.call(this, msg);
+  this.name = 'AmqpConnectionError';
+};
+util.inherits(errors.ConnectionError, errors.BaseError);
+
+/**
+ * Disconnected error
+ *
+ * @param msg
+ * @extends ConnectionError
+ * @constructor
+ */
+errors.DisconnectedError = function(msg) {
+  errors.ConnectionError.call(this, msg);
+  this.name = 'AmqpDisconnectedError';
+};
+util.inherits(errors.DisconnectedError, errors.ConnectionError);