Skip to content

Commit 7250e1e

Browse files
authored
Merge pull request #95 from macrozone/patch-1
fix: temporary mongodb outages stop job-queue forever
2 parents 3db5623 + aa1363f commit 7250e1e

File tree

1 file changed

+11
-6
lines changed
  • package/server/imports/operator/queue

1 file changed

+11
-6
lines changed

package/server/imports/operator/queue/index.js

Lines changed: 11 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -49,13 +49,18 @@ queue.prototype.trigger = function () {
4949
var self = this;
5050

5151
if (self.available === true && self.interval) {
52-
self.available = false;
52+
try {
53+
self.available = false;
5354

54-
if (dominator.isActive()) {
55-
self.run()
56-
} else {
55+
if (dominator.isActive()) {
56+
self.run()
57+
} else {
58+
self.available = true;
59+
}
60+
} catch(e) {
61+
console.error(e);
5762
self.available = true;
58-
}
63+
}
5964
}
6065
}
6166

@@ -114,4 +119,4 @@ queue.prototype.run = function () {
114119
}
115120
}
116121

117-
export { queue }
122+
export { queue }

0 commit comments

Comments
 (0)