SEGMENTATION USING MQ/WMQI

[kiaras]

Hi,
I have a message FLOW A, that receives messages in segments, the messages sit on the output q OF FLOW A until the last segment is received. I have a second flow that I want to use to reassemble these messages into one message. The output of the first FLOW A is the input of the second FLOW B. However when the output of FLOW A arrives to input of FLOW B, I can see the correct number of segments, but these do not reassemle into one message at the output of FLOW B. The output of FLOW B just shows the last segment.

How do I reassemle segmented messages?
Any thoughts would be greatly appreciated!!
thanks
k

 

[mqonnet]

There could be some option or attribute that you just select that would do this for you in WMQI. Unfortunately, i am not sure of it as i havent played much with it.

Check the docs, there must be something in there.

But again, if it is not supported, then its pretty simple for your application that gets the messages off Flow B to reassemble all of the segments into a single message.

Hope this helps.



Cheers
KK

 

[kiaras]

Hi and thanks for the reply, as far as I can see MQSI does not support this functionality of MQ. When you say it would be easy for my app to reassemble these msgs can you explain to me how this would be done?I was hoping that a message flow could do this for me..

Also I have found this option that I think may be of use but I do not know how to set it
GMO.Options = MQGMO_COMPLETE_MSG | (existing options)
MQGET

ould u know anything about this?
many thanks
k

 

[mqonnet]

You got it.

Thats precisely how you get all the segments assembled. But make sure that the buffer into which you would be copying all those segments has enough to accomodate all the segments.



Cheers
KK

 

[kiaras]

thanks but do you know how i set this option? or where I set it is it within MQ or within the integrator - i tried setting this withing a compute node but it couldnt understand it

 

[mqonnet]

Well, as i said, i am not that sure of the integrator and how you could do this.

Within your MQ app though, you set this in the get options just before issuing MQGET. Take amqsget sample source and modify it by adding MQGMO_COMPLETE_MSG option to the get options. And change the buffer size. Run this new amqsget app on FLOW B to retrieve all the messages.

Good luck.



Cheers
KK