@cap-js-community/event-queue
Advanced tools
Comparing version 0.1.56 to 0.1.57
{ | ||
"name": "@cap-js-community/event-queue", | ||
"version": "0.1.56", | ||
"description": "event queue for cds", | ||
"version": "0.1.57", | ||
"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.", | ||
"main": "src/index.js", | ||
@@ -12,2 +12,12 @@ "files": [ | ||
], | ||
"keywords": [ | ||
"CAP", | ||
"CDS", | ||
"messaging", | ||
"async", | ||
"redis", | ||
"load-balancing", | ||
"eventing", | ||
"multi-tenancy" | ||
], | ||
"scripts": { | ||
@@ -35,4 +45,4 @@ "test:unit": "jest --testPathIgnorePatterns=\"/test-integration/\"", | ||
"dependencies": { | ||
"uuid": "9.0.0", | ||
"redis": "4.6.8", | ||
"uuid": "9.0.1", | ||
"redis": "4.6.10", | ||
"verror": "1.10.1", | ||
@@ -44,3 +54,3 @@ "yaml": "2.3.2" | ||
"@sap/cds-dk": "7.1.1", | ||
"hdb": "0.19.5", | ||
"hdb": "0.19.6", | ||
"eslint-plugin-node": "11.1.0", | ||
@@ -50,6 +60,6 @@ "sqlite3": "5.1.6", | ||
"@sap/cds": "7.1.2", | ||
"eslint": "8.48.0", | ||
"eslint": "8.50.0", | ||
"eslint-config-prettier": "9.0.0", | ||
"eslint-plugin-jest": "27.2.3", | ||
"jest": "29.6.4", | ||
"eslint-plugin-jest": "27.4.0", | ||
"jest": "29.7.0", | ||
"prettier": "3.0.3" | ||
@@ -56,0 +66,0 @@ }, |
@@ -16,3 +16,3 @@ # @cap-js-community/event-queue | ||
- Run `npm add @cap-community/event-queue` in `@sap/cds` project | ||
- Run `npm add @cap-js-community/event-queue` in `@sap/cds` project | ||
- Activate the cds-plugin in the cds section of the package.sjon | ||
@@ -19,0 +19,0 @@ |
@@ -50,3 +50,5 @@ "use strict"; | ||
if (!configInstance.redisEnabled) { | ||
await _handleEventInternally(tenantId, type, subType); | ||
if (configInstance.registerAsEventProcessor) { | ||
await _handleEventInternally(tenantId, type, subType); | ||
} | ||
return; | ||
@@ -90,3 +92,3 @@ } | ||
}); | ||
processEventQueue(context, type, subType); | ||
getWorkerPoolInstance().addToQueue(async () => processEventQueue(context, type, subType)); | ||
}; | ||
@@ -93,0 +95,0 @@ |
107921
2460
+ Added@redis/client@1.5.11(transitive)
+ Added@redis/json@1.0.6(transitive)
+ Added@redis/search@1.1.5(transitive)
+ Addedredis@4.6.10(transitive)
+ Addeduuid@9.0.1(transitive)
- Removed@redis/client@1.5.9(transitive)
- Removed@redis/json@1.0.4(transitive)
- Removed@redis/search@1.1.3(transitive)
- Removedredis@4.6.8(transitive)
- Removeduuid@9.0.0(transitive)
Updatedredis@4.6.10
Updateduuid@9.0.1