@cap-js-community/event-queue
Advanced tools
Comparing version 1.3.2 to 1.3.3
{ | ||
"name": "@cap-js-community/event-queue", | ||
"version": "1.3.2", | ||
"version": "1.3.3", | ||
"description": "An event queue that enables secure transactional processing of asynchronous and periodic events, featuring instant event processing with Redis Pub/Sub and load distribution across all application instances.", | ||
@@ -50,5 +50,5 @@ "main": "src/index.js", | ||
"devDependencies": { | ||
"@cap-js/hana": "^0.0.5", | ||
"@cap-js/hana": "^0.0.6", | ||
"@cap-js/sqlite": "^1.5.0", | ||
"@sap/cds": "^7.5.3", | ||
"@sap/cds": "^7.7.0", | ||
"@sap/cds-dk": "^7.5.1", | ||
@@ -55,0 +55,0 @@ "eslint": "^8.56.0", |
@@ -31,3 +31,3 @@ "use strict"; | ||
impl: "./housekeeping/EventQueueDeleteEvents", | ||
load: 1, | ||
load: 20, | ||
interval: 86400, // 1 day, | ||
@@ -34,0 +34,0 @@ internalEvent: true, |
@@ -33,3 +33,3 @@ "use strict"; | ||
["isEventQueueActive", true], | ||
["runInterval", 5 * 60 * 1000], | ||
["runInterval", 25 * 60 * 1000], | ||
["tableNameEventQueue", BASE_TABLES.EVENT], | ||
@@ -36,0 +36,0 @@ ["tableNameEventLock", BASE_TABLES.LOCK], |
@@ -14,3 +14,2 @@ "use strict"; | ||
const COMPONENT_NAME = "/eventQueue/processEventQueue"; | ||
const MAX_EXECUTION_TIME = 5 * 60 * 1000; | ||
@@ -119,3 +118,3 @@ const processEventQueue = async (context, eventType, eventSubType, startTime = new Date()) => { | ||
} | ||
if (new Date(startTime.getTime() + MAX_EXECUTION_TIME) > new Date()) { | ||
if (new Date(startTime.getTime() + config.runInterval) > new Date()) { | ||
return true; | ||
@@ -122,0 +121,0 @@ } |
160855
3957