|
RSS Feed - WebSphere MQ Support
|
RSS Feed - Message Broker Support
|
 |
|
Collector Node - CorrelId |
« View previous topic :: View next topic » |
Author |
Message
|
pottas |
Posted: Fri Nov 04, 2011 4:11 am Post subject: Collector Node - CorrelId |
|
|
 Disciple
Joined: 27 Oct 2005 Posts: 185 Location: South Africa
|
Guys,
I am running WMB 7.0.0.2.
I am attempting to use the Collector Node and I have set it up with two MQ queues feeding into two terminals created on the Collector Node.
The properties on the 'Basic' tab I have set up with a Correlation path as '$Root/MQMD/CorrelId' - for both input terminals.
So, I am expecting that the Collector Node will collect the first message, start a new collection, wait for the second message, and if the 2nd message matches the Correlation Id of the 1st message, complete the collection and spit it out on the Out terminal to be processed further.
But, it doesn't matter what my Correlation Id is set to, the collection completes once it received *any* two message, regardless of the Correlation Id of the messages.
Obviously I am missing something somewhere....
Thanks |
|
Back to top |
|
 |
Vitor |
Posted: Fri Nov 04, 2011 5:09 am Post subject: |
|
|
 Grand High Poobah
Joined: 11 Nov 2005 Posts: 26093 Location: Texas, USA
|
Why 2 input terminals?
Each collection is unique to the input terminal you've defined. So if you have a Collector node with an input terminal A set as you've described, and another input terminal B likewise then the first 2 messages with the same correl id that arrive on A within the collection expiry should come out as a collection called A. Likewise on B.
If 1 message arrives on A, and another arrives on B with the same correl id you should get 2 collections started, both of which should come out of the expiry terminal after expiry.
Are you sure your messages are a) in the same collection and b) emitting from the Out terminal not the expire terminal?
Also what do you have the collection name set to? If it's blank that may be disgusing the fact these messages are in 2 different collections. Try * to name them for their handler. _________________ Honesty is the best policy.
Insanity is the best defence. |
|
Back to top |
|
 |
pottas |
Posted: Fri Nov 04, 2011 5:21 am Post subject: |
|
|
 Disciple
Joined: 27 Oct 2005 Posts: 185 Location: South Africa
|
Ok, so you are saying if I configure the collector node with an input terminal (IN1), and I expect to get 2 messages from different queues (Q1 and Q2), these queues should be connected to the terminal IN1 for it to constitute a collection? If this is the case, then I have mis-intrpreted it completely.
Thanks for your reply. |
|
Back to top |
|
 |
Vitor |
Posted: Fri Nov 04, 2011 5:26 am Post subject: |
|
|
 Grand High Poobah
Joined: 11 Nov 2005 Posts: 26093 Location: Texas, USA
|
pottas wrote: |
you are saying if I configure the collector node with an input terminal (IN1), and I expect to get 2 messages from different queues (Q1 and Q2), these queues should be connected to the terminal IN1 for it to constitute a collection? |
You should get 2 messages in a collection called IN1 (if you use * in the collection name). _________________ Honesty is the best policy.
Insanity is the best defence. |
|
Back to top |
|
 |
pottas |
Posted: Fri Nov 04, 2011 5:40 am Post subject: |
|
|
 Disciple
Joined: 27 Oct 2005 Posts: 185 Location: South Africa
|
Aaah, OK, that is a bit more clear then.
You must please excuse... English is my second language, sometimes my third... |
|
Back to top |
|
 |
Vitor |
Posted: Fri Nov 04, 2011 5:59 am Post subject: |
|
|
 Grand High Poobah
Joined: 11 Nov 2005 Posts: 26093 Location: Texas, USA
|
pottas wrote: |
You must please excuse... English is my second language, sometimes my third... |
No problem.
I suffer from the same problem sometimes. _________________ Honesty is the best policy.
Insanity is the best defence. |
|
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
|
|
|
|