You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
I have used amqp10 npm module, I am seeing following issues, can you please address those. I will help me a lot.
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.*.
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.
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
The text was updated successfully, but these errors were encountered:
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.
Hi,
I have used amqp10 npm module, I am seeing following issues, can you please address those. I will help me a lot.
I want to get all the queue names which start with data.*.
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.
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
The text was updated successfully, but these errors were encountered: