integreat-queue-rabbitmq
v0.1.0
Published
RabbitMQ queue for Integreat – based on amqp.node
Downloads
4
Readme
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.