MQSeries.net :: View topic

gmmqnet · Posted: Fri Jan 30, 2015 12:26 pm Post subject:

Environment - IIB 9.0.02 and WMQ 7.5.0.1
Use Case - Single request with multiple stock symbols are received for quotes. External webservice can handle only one symbol in a request. The response should contain all the stock quotes of the incoming request-which probably can be done using aggregation.
-------------Solution with Aggregate Nodes-----------

Request Flow -
MQInput->AggControl->ComputeNode(Propagate single request)->MQOutput(Input for StockQuote WebSvc)->AggRequest

StockQuote Web Service
MQInput->Compute(Save MQ Header)->SOAPEnvelope->SOAPRequest->Compute(Create Rep with saved MQ Header)->MQReply(Input for AggReply)

Reply Flow
MQInput->AggReply->ComputeNode(Aggregate all single requests)->MQOutput

-------------Solution with Collector Node-----------
Request Flow -
MQInput->ComputeNode(Propagate single request)->MQOutput(Input for StockQuote WebSvc)->AggRequest
->Timer Control for collector
StockQuote Web Service
MQInput->Compute(Save MQ Header)->SOAPEnvelope->SOAPRequest->Compute(Create Rep with saved MQ Header)->MQReply(Input for AggReply)

Reply Flow
TimerNotification(To Collector Control)->
MQInput ->Collector->ComputeNode(Aggregate all single requests)->MQOutput

Problem/Issue-
If I were to use Collector node I need to use MQOutput node in the webservice as MQReply changes the correlid. This can be done away with by using
SET OutputRoot.MQMD.Report = MQRO_PASS_CORREL_ID
But with the above property the Aggregate nodes dont work as the aggregate correlid gets messed up. Is this expected behaviour?
I intend to have the webservice call as a reusable component for other services.