|
RSS Feed - WebSphere MQ Support
|
RSS Feed - Message Broker Support
|
 |
|
Joining Messages that belong to a given Message Group? |
« View previous topic :: View next topic » |
Author |
Message
|
AviD |
Posted: Wed Mar 19, 2008 9:31 am Post subject: Joining Messages that belong to a given Message Group? |
|
|
Acolyte
Joined: 06 Apr 2004 Posts: 62
|
Pretty straightforward question, did some searching but didn't come up with much in WMB samples.
WMB Version: 6.0.2
Build id: 20061201_1308
What is common practice for joining messages that are sent over MQ as a message group?
In the MQInput node, I can set:
- Order mode by Queue Order
- Logical Order
- All Messages Available
The behavior I've observed is that the messages will only be sent through once all messages in the group have arrived.
Now the question is, what is the best way to merge them into a singular message?
I can think of a few ways to do this, but I'd imagine there is some very easy way that is commonly used by I'm struggling to find it...maybe something already built in WMB.
Can someone point me in the right direction? |
|
Back to top |
|
 |
mqmatt |
Posted: Wed Mar 19, 2008 9:41 am Post subject: |
|
|
 Grand Master
Joined: 04 Aug 2004 Posts: 1213 Location: Hursley, UK
|
|
Back to top |
|
 |
AviD |
Posted: Wed Mar 19, 2008 2:10 pm Post subject: |
|
|
Acolyte
Joined: 06 Apr 2004 Posts: 62
|
mqmatt:
Thanks for the reply!
So basically, in 6.0.2, the MQInput node can detect when a message group is complete...but not really do anything with it?
Right now, I am seeing that messages are held in the queue until the last message is sent and then each message is sent individually...one by one...and processed through the flow.
I don't see a way to iterate through the message sequencing/group to even access each message in a single UOW.
Am I missing something?
Even a JCN won't help me here, since I can't re-issue a call to the MQInput to grab the next message in the sequence.
Ultimately (since I cannot upgrade to 6.1 at this time), I'll likely have to port this entirely out of WMB and write a standalone program to handle the processing.
I looked at the Aggregate nodes, but don't see how I can achieve the message grouping and merging either since I am not controlling the input. The start of the entire process is messages landing on an input queue from another system's application (non-WMB). So I can't associate the input stream with an Aggregate Request and the output stream with an Aggregate Reply. Even if I could, like you said, I don't have a means to isolate and correlate a given message group.
Any other ideas before I port out and write a standalone Java program to do the work? |
|
Back to top |
|
 |
jefflowrey |
Posted: Wed Mar 19, 2008 2:48 pm Post subject: |
|
|
Grand Poobah
Joined: 16 Oct 2002 Posts: 19981
|
You can process the messages one by one and store them in a container of some kind - database, perhaps - and then use the group flag for last message to signal that you should repropagate the collected data.
You can't otherwise do this in v6.0 of Broker in a reasonable way. _________________ I am *not* the model of the modern major general. |
|
Back to top |
|
 |
AviD |
Posted: Thu Mar 20, 2008 7:01 am Post subject: |
|
|
Acolyte
Joined: 06 Apr 2004 Posts: 62
|
Jeff:
Thanks for the additional reply.
Ugh!  |
|
Back to top |
|
 |
sunny_30 |
Posted: Fri Mar 21, 2008 7:04 am Post subject: |
|
|
 Master
Joined: 03 Oct 2005 Posts: 258
|
|
Back to top |
|
 |
|
|
 |
|
Page 1 of 1 |
|
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
|
|
|
|