cqrs-eventdenormalizer
Advanced tools
Comparing version 1.9.34 to 1.9.35
@@ -145,2 +145,5 @@ 'use strict'; | ||
// just to make sure callback gets not called twice... | ||
callback = _.once(callback); | ||
this.queue.push(concatenatedId, evtId, evt, callback, function (loopCount, waitAgain) { | ||
@@ -156,3 +159,3 @@ self.store.get(concatenatedId, function (err, revInStore) { | ||
debug('revision match [concatenatedId]=' + concatenatedId + ', [revInStore]=' + revInStore + ', [revInEvt]=' + revInEvt); | ||
return; | ||
return self.guard(evt, callback); | ||
} | ||
@@ -159,0 +162,0 @@ |
{ | ||
"author": "adrai", | ||
"name": "cqrs-eventdenormalizer", | ||
"version": "1.9.34", | ||
"version": "1.9.35", | ||
"private": false, | ||
@@ -6,0 +6,0 @@ "main": "index.js", |
@@ -0,1 +1,4 @@ | ||
## [v1.9.35](https://github.com/adrai/node-cqrs-eventdenormalizer/compare/v1.9.34...v1.9.35) | ||
- Fix events getting lost at high concurrency | ||
## [v1.9.34](https://github.com/adrai/node-cqrs-eventdenormalizer/compare/v1.9.31...v1.9.34) | ||
@@ -2,0 +5,0 @@ - Support mongo connection string |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
171617
3968