search

noodlefrenzy / node-amqp10

amqp10 is a promise-based, AMQP 1.0 compliant node.js client
MIT License
134 stars 56 forks source link

Issues with amqp10 npm module #374

Open mailmeankit opened 6 years ago

mailmeankit commented 6 years ago

Hi,

I have used amqp10 npm module, I am seeing following issues, can you please address those. I will help me a lot.

  1. I am unable to get queue names based on naming pattern, for example, if there are multiple queue's i.e data.pipeline,data.enabling,...etc.

I want to get all the queue names which start with data.*.

  1. Next, I am unable to find when all messages from the queue consumed i.e no event raised when all messages are consumed from the queue.

  2. Also, I need to send an acknowledgement when a message is consumed by me as I can do it using receiver.accept(message), but this can be done when the session is still open.

I need to consume message from the queue, and launch my worker function via API gateway and pass my consumed message and then worker lambda then process the message and send an acknowledgement.

As this doesn't seem to be working.

Can you please help me or do I need to use any other module, I learned about rhea module but not sure will it able to solve my above issues.

Thanks

amarzavery commented 6 years ago

This repo is no longer actively maintained. Please use https://github.com/amqp/rhea which is a fully compliant amqp 1.0 library that is actively maintained.