adds retry when pull subscriptions fails

agsh · May 13, 2024 · cbefaa3 · cbefaa3
1 parent 8d7aefc
commit cbefaa3
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 0 deletions.
diff --git a/lib/cam.js b/lib/cam.js
@@ -86,6 +86,7 @@ var Cam = function(options, callback) {
 	this.path = options.path || '/onvif/device_service';
 	this.timeout = options.timeout || 120000;
 	this.agent = options.agent || false;
+	this.eventReconnectms = options.eventReconnectms;
 	/**
 	 * Force using hostname and port from constructor for the services
 	 * @type {boolean}

diff --git a/lib/events.js b/lib/events.js
@@ -349,6 +349,8 @@ module.exports = function(Cam) {
 				this.createPullPointSubscription(function(error) {
 					if (!error) {
 						this._eventPull();
+					} else if (this.eventReconnectms) {
+						setTimeout(() => this._eventRequest(), this.eventReconnectms);
 					}
 				}.bind(this));
 			} else {