@cap-js-community/event-queue - npm Package Compare versions

Comparing version 1.0.0 to 1.0.1

package.json

 {
   "name": "@cap-js-community/event-queue",
-  "version": "1.0.0",
+  "version": "1.0.1",
   "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.",
@@ -50,7 +50,7 @@ "main": "src/index.js",
   "devDependencies": {
-    "@sap/cds": "7.5.0",
+    "@sap/cds": "7.5.1",
     "@sap/cds-dk": "7.5.0",
     "eslint": "8.56.0",
     "eslint-config-prettier": "9.1.0",
-    "eslint-plugin-jest": "27.6.0",
+    "eslint-plugin-jest": "27.6.1",
     "eslint-plugin-node": "11.1.0",
@@ -61,3 +61,3 @@ "express": "4.18.2",
     "prettier": "2.8.8",
-    "sqlite3": "5.1.6"
+    "sqlite3": "5.1.7-rc.0"
   },
@@ -64,0 +64,0 @@ "homepage": "https://cap-js-community.github.io/event-queue/",

src/config.js

@@ -53,2 +53,3 @@ "use strict";
   #isPeriodicEventBlockedCb;
+  #thresholdLoggingEventProcessing;
   static #instance;
@@ -400,2 +401,10 @@ constructor() {
 
+  set thresholdLoggingEventProcessing(value) {
+    this.#thresholdLoggingEventProcessing = value;
+  }
+
+  get thresholdLoggingEventProcessing() {
+    return this.#thresholdLoggingEventProcessing;
+  }
+
   get isMultiTenancy() {
@@ -402,0 +411,0 @@ return !!cds.requires.multitenancy;

src/EventQueueProcessorBase.js

@@ -134,3 +134,3 @@ "use strict";
     this.__performanceLoggerEvents?.endPerformanceTrace(
-      { threshold: 50 },
+      { threshold: this.#config.thresholdLoggingEventProcessing },
       {
@@ -145,3 +145,3 @@ eventType: this.#eventType,
     this.__performanceLoggerPeriodicEvents?.endPerformanceTrace(
-      { threshold: 50 },
+      { threshold: this.#config.thresholdLoggingEventProcessing },
       {
@@ -148,0 +148,0 @@ eventType: this.#eventType,

src/initialize.js

@@ -37,2 +37,3 @@ "use strict";
   ["updatePeriodicEvents", true],
+  ["thresholdLoggingEventProcessing", 50],
 ];
@@ -51,2 +52,3 @@
   updatePeriodicEvents,
+  thresholdLoggingEventProcessing,
 } = {}) => {
@@ -72,3 +74,4 @@ // TODO: initialize check:
     skipCsnCheck,
-    updatePeriodicEvents
+    updatePeriodicEvents,
+    thresholdLoggingEventProcessing
   );
@@ -75,0 +78,0 @@

No alert changes

Improved metrics

Total package byte prevSize

143011

increased by0.31%

Lines of code

3420

increased by0.29%

No dependency changes