mq-reconnect.js

mq-reconnect.js

...
conn.on("close", function() {
            winston.error("-> mq.connection: close event received");
            mq.channel = null;

            // Try to reconnect every X seconds
            let timer = setInterval(function () {
                              winston.info('-> mq.connection: trying to reconnect...');
                              mq.connect((err) => {
                                  if (err) {
                                      winston.error(util.format("-> mq.connection: reconnection failed [%s]", err.message));
                                  } else {
                                      winston.info(util.format("-> app: mq.connect succeeded"));
                                      clearInterval(timer);
                                  }
                              });
                          }, 3000);
});