How to use AMQP adapter in between an iFlow . I need to read messages from queue every 15 minutes ,so have a timer which is scheduled to run every 15 minutes . But I am not able to read messages from queue in between an iFlow using OOTB components
Can you share why you need to read messages from the queue every 15 minutes? When you have AMQP Sender subscribed to a queue, it reads the messages from the queue as soon as they are posted there and starts the iFlow. You don't need to implement any scheduler separately. For general concepts of event-oriented architecture please see Event Mesh Default Plan Concepts.
I am aware that AMQP reads messages as soon as it's posted into a queue and my use case does not sync with event driven arch .My use case is that I have an iflow A which calls a service which triggers a job internally and returns an ID.I store this I'd in a queue.And after every 15 minutes pickup this Id from the queue using Ifalow B and check the status of the job if it's complete.If it's comple remove the message from the queue else repush it into queue ,so that I can check if it's completed the next time.
In this case, you should use Datastore, Variable or external database (via JDBC) to store the ID. Then you can trigger the process to pickup this ID and check the status of the job via Scheduler.
Bluesky
You must be a registered user to add a comment. If you've already registered, sign in. Otherwise, register and sign in.