Author |
Message
|
atul_jain1981 |
Posted: Mon Apr 06, 2009 6:07 am Post subject: Collector Node -Multithreaded ? |
|
|
Novice
Joined: 27 Apr 2008 Posts: 10
|
Hi
I am having a situation in which there in one MQ input node from which file name information is coming and on the basis of this i need to pick same file from File system using FILE INPUT node.
I am using Collector node for the same, where MQ is one input and File Input is another input and I set coreation filed with respect to file name and its work fine.
I need to know do the Collector node works as Multithreaded node. As if i put this node in productin with multiple instances of MQ input and FileInput node then do I have multiple thread of Collector node in envoronment.
Please help me in the same  |
|
Back to top |
|
 |
atul_jain1981 |
Posted: Thu Jul 16, 2009 1:46 pm Post subject: Collector Node -Multithreaded ? |
|
|
Novice
Joined: 27 Apr 2008 Posts: 10
|
Any views on the same ?
It works fine in single instance envoronment !! But i m really looking
for help in MultiInstance of Flow environment in same execution group.
 |
|
Back to top |
|
 |
mqjeff |
Posted: Thu Jul 16, 2009 5:06 pm Post subject: |
|
|
Grand Master
Joined: 25 Jun 2008 Posts: 17447
|
Collector node and threading is a very complicated subject.
You need to remember that the OUT side of the Collector node is A New Message Flow from everything on the IN side. It starts a new thread and runs in a new instance.
Yes, you should be able to assign multiple threads to the FileInput and the MQInput node, or to the flow as a whole. You will have to ensure that your code does not depend on the order in which the two inputs will appear on the Collection tree. There's specific comments on that in the description of the node in the InfoCenter. |
|
Back to top |
|
 |
atul_jain1981 |
Posted: Fri Jul 17, 2009 9:30 am Post subject: |
|
|
Novice
Joined: 27 Apr 2008 Posts: 10
|
hey mqjeff
Thanks for your reply !!
scenario 1 : (0 Additional Instance)
I have attached File input and MQ input node to Collector node with
0 additional instance of flow and then I have put 5 msg in Queue and
5 Files. All got corelated and I i got cellected msg after collector node.
scenario 2 : (5 Additional Instance)
Then i tried same Message Flow with 5 additional instance of message flow and no msg got correated and all went to Expire terminal.
So plz let me know.....with this can we say that we need to run only one instace of messag flow containing collector node and we not be able to achieve multithreading. |
|
Back to top |
|
 |
JosephGramig |
Posted: Fri Jul 17, 2009 11:42 am Post subject: |
|
|
 Grand Master
Joined: 09 Feb 2006 Posts: 1244 Location: Gold Coast of Florida, USA
|
Hmmm, I think you didn't repeat the test correctly.
Say you have no additional instances. You will have one thread per input node and another thread for each match. The match threads obviously go away at the end of that instance of the message flow.
Say there are no messages going through the flow, then there are only two threads. |
|
Back to top |
|
 |
|