fix: add small reconnection delay

microfleet · Nov 28, 2016 · a6eaefd · a6eaefd
1 parent 27eb227
commit a6eaefd
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/amqp.js b/src/amqp.js
@@ -441,7 +441,7 @@ class AMQPTransport extends EventEmitter {
 
         return [consumer, queue];
       })
-      .catch(Errors.ConnectionError, establishConsumer);
+      .catch(Errors.ConnectionError, () => Promise.delay(500).then(establishConsumer));
     }
 
     // make sure we recreate queue and establish consumer on reconnect