feat: add heartbeat (#20)

Author: reyhansofian

lib/service_amqp.js

@@ -27,7 +27,7 @@ module.exports = class Amqp extends Component.mixin(AsyncEmitter) {
     *doConnect() {
         if (this._initializing) return;
         this._initializing = true;
-        let { secure, user, password, host, port, connectionString } = this.config.default("service.rabbit", { host: "localhost", port: 5672 });
+        let { secure, user, password, host, port, connectionString, heartbeat } = this.config.default("service.rabbit", { host: "localhost", port: 5672, heartbeat: 20 });
 
         let protocol = (typeof secure === "boolean" && secure) ? "amqps" : "amqp";
 
@@ -41,9 +41,11 @@ module.exports = class Amqp extends Component.mixin(AsyncEmitter) {
                 connectionString = `${protocol}://${host}:${port}`;
             }
         }
+        
+        let connectionStringOpts = `${connectionString}?heartbeat=${heartbeat}`;
 
         try {
-            this._connection = yield amqp.connect(connectionString);
+            this._connection = yield amqp.connect(connectionStringOpts);
 
             this.logger.info("Connected to rmq.");
 

package.json

@@ -1,6 +1,6 @@
 {
     "name": "merapi-plugin-service-rabbit",
-    "version": "0.5.2",
+    "version": "0.6.1",
     "description": "Provide RabbitMQ integration interface",
     "main": "index.js",
     "scripts": {
@@ -41,4 +41,4 @@
         "nyc": "^13.3.0",
         "supertest": "^3.3.0"
     }
-}
+}