Author |
Message
|
santy |
Posted: Mon Mar 01, 2010 8:05 am Post subject: Bulk same messages |
|
|
Centurion
Joined: 03 Nov 2006 Posts: 141
|
Hi,
I'm working on WMB 6.1 and we have a requirement where we will be receiving diff. types of messages and we have to find out the similar messages from message contents and we have to bulk 99 same messages in one file or we have to wait for 1 min to receive same group of messages and then bulk them in 1 file.
Please can anybody suggest how to achive this? |
|
Back to top |
|
 |
Vitor |
Posted: Mon Mar 01, 2010 8:19 am Post subject: Re: Bulk same messages |
|
|
 Grand High Poobah
Joined: 11 Nov 2005 Posts: 26093 Location: Texas, USA
|
santy wrote: |
Please can anybody suggest how to achive this? |
A database and a timer node is one way.
You might get somewhere with the new Collector node as well. But I'm less certain on that.
Do you have to assemble lists of all the message types and send them? Or just pull out one particular type and batch that up? There must be an easier way to handle this requirement, possibly by giving them what they need not what they're asking for.
Which is another way of saying this design has issues. _________________ Honesty is the best policy.
Insanity is the best defence. |
|
Back to top |
|
 |
zpat |
Posted: Mon Mar 01, 2010 8:48 am Post subject: |
|
|
 Jedi Council
Joined: 19 May 2001 Posts: 5866 Location: UK
|
If the messages are sent as a message group (in MQ terms) you can make the MQInput node wait until the entire group of messages is available (check the All Messages Available box).
Or use a MQinput node to catch the first message and use a compute node propagate loop with a MQGet node to get the remainder - setting the MQGet WAIT interval to your desired value.
The propagate logic is slightly hard to visualise, let me know if you want more details. |
|
Back to top |
|
 |
Vitor |
Posted: Mon Mar 01, 2010 9:00 am Post subject: |
|
|
 Grand High Poobah
Joined: 11 Nov 2005 Posts: 26093 Location: Texas, USA
|
zpat wrote: |
Or use a MQinput node to catch the first message and use a compute node propagate loop with a MQGet node to get the remainder - setting the MQGet WAIT interval to your desired value.
|
Doesn't this rather assume they're all sent as a block? What happens here if they're intersperced with other messages?
Not a problem with your other suggestion I hasten to point out. _________________ Honesty is the best policy.
Insanity is the best defence. |
|
Back to top |
|
 |
jbanoop |
Posted: Mon Mar 01, 2010 2:49 pm Post subject: |
|
|
Chevalier
Joined: 17 Sep 2005 Posts: 401 Location: SC
|
if you are dealing with a finite set of different message types you could use multiple collector nodes to implement this requirement.
Have a node inspect the message content to identify message type and depending on the type route it to a collector node. You can 1 collector node for each message type.
You can set the quantity to 99 and timeout to 120 seconds on each of the collector nodes to achieve your requirement.
Hope this helps. |
|
Back to top |
|
 |
|