Hi All,
I have a requirement to build a retry logic based on whether the particular record is updated in the table or not. My design is as shown below with 2 independent flows which are multi threaded.
Code:
Request Mesage flow
MQInput -> ComputeNode -> Send request to Insert request record -> Send message to Backend
Response Message flow
MQInput -> ComputeNode -> Send request to Update the status of inserted record -> Check if all the rows associated with that group completed or not -> Send the response back to client
DB Flow
MQInput -> Insert the records
MQInput -> Update the records
If I make all the flows are multi threaded then I will not be sure if Insert happens only before Update operation.
If I perform Update operation first before Insert is done then it will fail entire design. So in order to over come this situation I wanted to know if Update really updated any records, if it is not updated any records then retry that update operation.
Let me know if anyone has any inputs on this to know how many records are updated in table from within the Compute node.
What happens when an update fails on the DB? How is that reflected in the flow?
In this case I am expecting SQL error will be thrown from the DB and it will be handled in the flow.
My query is to know how many records are updated by the UPDATE flow. Based on this result I can decide whether I have to retry in my flow for UPDATE operation or not.
Hope this is clear now....
You cannot post new topics in this forum You cannot reply to topics in this forum You cannot edit your posts in this forum You cannot delete your posts in this forum You cannot vote in polls in this forum