RabbitMQ queue for Integreat
This implementation is based on amqp.node.
Getting started
Prerequisits
Requires node v14 and Integreat v0.8.
Installing
Install from npm:
npm install integreat-queue-rabbitmq
Options
-
queueName
is used directly as the queue name in RabbitMQ. An exchange is created with the name<queueName>_exch
. -
maxConcurrency
specifies how many jobs may be picked from the queue before any of them is completed (acknowledged or rejected). Default is1
, meaning a new job will not be picked until the current one is done. Note that for RabbitMQ v3.3.0 and later, this is limited to a channel, i.e. one instance of an Integreat queue, so with amaxConcurrency
of 1 on several instances, each one may pick one job. In versions before v3.3.0, only one job could be picked across all subscribers. -
rabbitmq
may be an url string or the options object required by theconnect()
method of theamqp
client. The most common props of this object arehostname
,port
,username
, andpassword
.
Running the tests
The tests can be run with npm test
.
Contributing
Please read CONTRIBUTING for details on our code of conduct, and the process for submitting pull requests.
License
This project is licensed under the ISC License - see the LICENSE file for details.