I tried this, but this will just to ignore the messages, no other
ruote-worker-process will pick up the work for this messages.
module Ruote
class MyWorker < Worker
def process(msg)
participant_name = msg['workitem']['participant_name'] rescue nil
unless participant_name =~ /high_priority/
return false
else
puts "Ruote::MyWorker.process(#{participant_name})"
super msg
end
end
end
end
Am Dienstag, 31. Juli 2012 12:39:42 UTC+2 schrieb Marco S:
>
> Hi,
>
> is there a way to 'reserve' workers for specific participants.
>
> We have the requirement that some workitems need to be processed quite
> instantly (1-2 seconds).
> But under medium workload the engine reacts really slow and needs minutes
> to process new workitems, even with a lot of worker-processes (currently
> 5).
>
> If it would be possible to reserve workers for specific jobs, we could
> ensure the workitems would be processed within time.
> Or is it possible to give an workitem some kind of priority?
>
> How many workers do you usually run in production?
>
> Thanks,
> Marco
>
--
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
