NestJS implementation of client and strategy hasn't enough features for work with RabbitMQ so i developed this one (basically, just a wrapper for amqp-connection-manager)
Features:
- Subscribe on queues/exchanges with routing-key and stuff
- Seingnding:
- Message acknowledgment
npm install --save [email protected]:i-link-pro-team/rabbit-mq.git
// Into existing exchange:
{
pattern?: string, // allow to define type of the message in queue
data: any // only json compatible
}
- amqp-connection-manager
- amqplib
See CLIENT.md
See STRATEGY.md
If you want to use strategy please provide transport-type into all of your 'MessagePattern'-decorators like this:
@MessagePattern(
{cmd: MessagePatternName},
Transport.TCP // <------- this line
)
someMethod() {}
I've no idea how to fix it yet