historical-deadletter-processor
Advanced tools
Comparing version 0.2.0 to 1.0.0
@@ -71,9 +71,16 @@ (function() { | ||
HistoricalDeadletterProcessor.prototype._doProcess = function(arg) { | ||
var notification; | ||
notification = arg.notification; | ||
this.logger.info("Processing", { | ||
notification: notification | ||
}); | ||
return highland(this.processor(notification)); | ||
HistoricalDeadletterProcessor.prototype._doProcess = function(row) { | ||
return highland((function(_this) { | ||
return function(push, next) { | ||
var __done; | ||
__done = function(err) { | ||
push(err, null); | ||
return push(null, highland.nil); | ||
}; | ||
return _this.processor({ | ||
done: __done, | ||
log: _this.logger | ||
}, row); | ||
}; | ||
})(this)); | ||
}; | ||
@@ -80,0 +87,0 @@ |
{ | ||
"name": "historical-deadletter-processor", | ||
"version": "0.2.0", | ||
"version": "1.0.0", | ||
"description": "historical-deadletter-processor", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
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
No v1
QualityPackage is not semver >=1. This means it is not stable and does not support ^ ranges.
Found 1 instance in 1 package
23732
91
0