OK, so I create my own Receiver (perhaps inheriting from RuoteAMQP::Receiver) and in there I can do whatever I want. As far as "correlation" is concerned, what I need to do is, find out the FEI to which to send the incoming data, get the workitem associated with that FEI, and plug in the data from the message.
Outbound messages get handled by my own Participant which needs to coordinate with the Receiver, perhaps storing the data needed for correlation somewhere where the Receiver can find it (perhaps a global Hash table, a database, or in the quantum state of the Universe) and associate it with the FEI. Correct? Also, is there a way of searching through all the stored workitems, to do the correlation? So, suppose the message comes with certain fields (for example, "source_token" and "message_type") that need to match data inside of the workitem (for example, fields called "expected_token" and "expected_message_type"). In that case I could either store the "expected_token" and "expected_message_type" someplace and associated with the FEI, so the Receiver can get at them, or have the Receiver search the stored workitems to find the FEI. What would be the preferred way of doing this? Thanks for all the support! I realize these are probably rather basic questions but again, I'm trying to map my knowledge of workflow systems and the things Gonzalo told me to how things work in Ruote. Cheers, -Mario. -- you received this message because you are subscribed to the "ruote users" group. to post : send email to [email protected] to unsubscribe : send email to [email protected] more options : http://groups.google.com/group/openwferu-users?hl=en
