notification-processor
npm install notification-processor
Javascript
//2.x
require("notification-processor").JobProcessor({
buildOpts: (message) => ({}), notificationApiUrl: "apiNotificationUrl"
})//3.x
require("notification-processor").JobProcessor({
apiUrl: "",
notificationApiUrl: ""
})
`New Features
* Adding request async processor`Javascript
require("notification-processor").RequestAsyncProcessor({
apiUrl: "baseAPI..."
silentErrors: []
})
`Migrating 1.x -> 2.x
Deadletter Processor
`Javascript
// 1.x
const buildOpts = (message) => { return .... }
deadletterProcessor = DeadletterProcessor({
connection: connection,
name: "aFunctionName",
maxDequeueCount: 1,
rowKeyGenerator: (message) => { return ...... }
}, processor())// 2.x
const buildOpts = (message) => { return .... }
const sender = {
resource: (notification) => { return ... }
user: (notification) => { return ... }
}
deadletterProcessor = DeadletterProcessor({
connection: connection,
name: "aFunctionName",
maxDequeueCount: 1,
sender: sender
}, processor())
`Job Processor
`JavaScript// 1.x
const buildOpts = (message) => { return .... }
const processor = JobsProcessor(buildOpts, nonRetryable)
// 2.x
const buildOpts = ({ message }) => { return ...... }
const processor = JobsProcessor({
buildOpts: optionsGenerator,
maxRetries,
nonRetryable
})
`To publish
`
npm version [major/minor/patch]
npm publish
git push origin HEAD
git push origin HEAD --tags
``