1.2.3 • Published 1 year ago
sqs-bull v1.2.3
Install
$ npm i @ghostmonitor/sqs-bull
Usage
const QueueWrapper = require('@ghostmonitor/gm-queue-wrapper');
const SomeQueueConfig = new QueueWrapper('gm-some-service');
const SqsBull = require('sqs-bull');
const queue = new SqsBull({
queueUrl: SomeQueueConfig.getQueueUrl(), // required
visibilityTimeout: 30
attributeNames: [],
messageAttributeNames: [],
concurrency: 1,
longPollWaitTimeSeconds: 20,
authenticationErrorTimeout: 10000,
sqsSignatureVersion: 'v4',
disableMessageProcessingTimeout: false,
processNonJson: false,
restartOnUnexpectedError: true,
unexpectedErrorDelay: 10000
});
queue.on('processing_error', (err) => {
console.error('Error processing message', err.message, err.stack)
})
queue.process(async (message) => {
// do processing...
})
Testing
$ docker run -p 9324:9324 -p 9325:9325 softwaremill/elasticmq
$ npm test
1.2.3
1 year ago
1.2.1
3 years ago
1.1.0
3 years ago
1.0.0
3 years ago
0.2.5
3 years ago
0.2.4
3 years ago
0.2.3
4 years ago
0.2.2
4 years ago
0.2.1
4 years ago
0.1.17
6 years ago
0.1.16
6 years ago
0.1.14
6 years ago
0.1.13
6 years ago
0.1.11
6 years ago
0.1.9
7 years ago
0.1.8
7 years ago
0.1.7
7 years ago
0.1.6
7 years ago
0.1.5
7 years ago
0.1.4
7 years ago
0.1.3
7 years ago
0.1.2
7 years ago
0.1.1
7 years ago
0.1.0
7 years ago