MultiConsumer Bull
A multi-consumer queue implementation using Bull queue.
Installation
npm install --save multiconsumer-bull
Usage examples
// Process "my-topic" for loggingbus.topic"my-topic".process"log", // Save all "my-topic" messages to databasebus.topic"my-topic".process"save", bus.topic"my-topic".add"Hello World!"
NOTE: Wrapper implementation is not removing consumer groups from RedisLiveSet
so once you're
not interested anymore for processing topic messages for specific groupId
-
you must remove that group and tasks manually
Group can be removed using MultiConsumerQueueImpl.removeGroup()
method:
// deploy this to your servers to stop collecting tasksbus.topic"my-topic".removeGroup"old-process-group"
You will still have to manually remove tasks already added for that group, or maybe those may expire,
this depends on how source NamedQueue
is implemented.
Contribute
Perfection is Achieved Not When There Is Nothing More to Add, But When There Is Nothing Left to Take Away
Fork, Contribute, Push, Create pull request, Thanks.
License
All code in this repository is licensed under the Apache License, Version 2.0. See LICENCE.