@cap-js-community/event-queue
Advanced tools
Comparing version 1.0.2 to 1.0.3
{ | ||
"name": "@cap-js-community/event-queue", | ||
"version": "1.0.2", | ||
"version": "1.0.3", | ||
"description": "An event queue that enables secure transactional processing of asynchronous events, featuring instant event processing with Redis Pub/Sub and load distribution across all application instances.", | ||
@@ -5,0 +5,0 @@ "main": "src/index.js", |
@@ -25,4 +25,6 @@ "use strict"; | ||
{ ref: ["status"] }, | ||
"=", | ||
{ val: EventProcessingStatus.Open }, | ||
"IN", | ||
{ | ||
list: [{ val: EventProcessingStatus.Open }, { val: EventProcessingStatus.InProgress }], | ||
}, | ||
]) | ||
@@ -29,0 +31,0 @@ .columns(["ID", "type", "subType", "startAfter"]); |
@@ -91,2 +91,3 @@ "use strict"; | ||
if (tenantIdHash && tenantIdHash !== hash) { | ||
tenantIdHash = hash; | ||
cds.log(COMPONENT_NAME).info("tenant id hash changed, triggering updating periodic events!"); | ||
@@ -304,3 +305,3 @@ _multiTenancyPeriodicEvents().catch((err) => { | ||
try { | ||
logger.info("executing updating periotic events", { | ||
logger.info("executing updating periodic events", { | ||
tenantId: context.tenant, | ||
@@ -307,0 +308,0 @@ subdomain: context.http?.req.authInfo.getSubdomain(), |
143290
3426