MQSeries.net :: View topic

radhika.tharayil · Posted: Fri Mar 29, 2013 3:40 am Post subject:

I am having a provider flow, which has a MQInput node followed by compute and the some downstream nodes.

I am using the compute node to send requests to multiple destinations one at a time. For which I am using the PROPAGATE statement. Below the code snippet.

DECLARE countDBResult INTEGER COALESCE(CARDINALITY(InputRoot.MQRFH2.usr.SOAP[]),0);
DECLARE j INTEGER 1;
WHILE j<=countDBResult DO

Some logicâ€¦â€¦â€¦â€¦â€¦

PROPAGATE TO TERMINAL 'out' DELETE NONE;

SET j = j + 1;
END WHILE;

RETURN FALSE;

The problem I face is if the countDBResult is 2 for e.g. Propagate will output two different messages out of compute node. But during this the original message is getting stored in the MQInput node input queue, and when the count of j reaches 3, the message flow restarts again by picking the message from the input queue and process it further 2 times. Hence if the countDBResult was 2, I get 4 outputs 2 for every iteration for a typical failure scenario where both the endpoints are down.