Hi everyone, I have a participant/receiver combination that extends RuoteAMQP::ParticipantProxy / RuoteAMQP::Receiver. The Participant doesn't call reply_to_engine in consume(), it just registers the workitem in an in-memory Hash and returns. The Receiver looks up the workitem in the Hash when it gets a message and does the receive (or a launch if there is no corresponding workitem).
What happens if Ruote goes down after the execution of the Participant but before the Receiver gets the message? Will the workitem be persisted (so I should probably persist the Hash too) or not? In my use case I think it makes more sense for it NOT to be persisted. As a matter of fact, I'm thinking of flushing the AMQP queue before starting up so we don't have any backed-up messages. -Mario. -- I want to change the world but they won't give me the source code. -- 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
