Merge pull request #5 from kata-ai/increase-expire-default-value

increase expires default value to 1 day

Author: ikmals

lib/service_pub_queue_rabbit.js

@@ -24,7 +24,7 @@ class ServicePubQueueRabbit extends Component.mixin(AsyncEmitter) {
         this._channels = {};
         this._registry = {};
         this._namespace = config.default("service.rabbit.namespace", "default");
-        this.expireTime = this.config.default("service.rabbit.expireTime", 1000 * 60 * 30); // 30 mins
+        this.expireTime = this.config.default("service.rabbit.expireTime", 1000 * 60 * 60 * 24); // 1 day
 
         this.servicePubQueue.on("triggerQueue", this.publishEvent.bind(this));
         this.amqp.on("connected", () => {

lib/service_sub_queue_rabbit.js

@@ -22,7 +22,7 @@ class ServiceSubRabbit extends ServiceSubQueue {
         this._connection = null;
         this._withExpire = true;
         this._namespace = config.default("service.rabbit.namespace", "default");
-        this.expireTime = this.config.default("service.rabbit.expireTime", 1000 * 60 * 30); // 30 mins
+        this.expireTime = this.config.default("service.rabbit.expireTime", 1000 * 60 * 60 * 24); // 1 day
 
         this.amqp.on("connected", () => {
             this.init();

lib/service_sub_rabbit.js

@@ -21,7 +21,7 @@ class ServiceSubRabbit extends ServiceSub {
 
         this.maxAttempts = this.config.default("service.rabbit.maxAttempts", 5);
         this.retryDelay = this.config.default("service.rabbit.retryDelay", 5000);
-        this.expireTime = this.config.default("service.rabbit.expireTime", 1000 * 60 * 30); // 30 mins
+        this.expireTime = this.config.default("service.rabbit.expireTime", 1000 * 60 * 60 * 24); // 1 day
         this.remainingAttempts = this.maxAttempts - 1;
 
         this._withExpire = true;