# #-- # Copyright (c) 2006-2007, John Mettraux, OpenWFE.org # All rights reserved. # # Redistribution and use in source and binary forms, with or without # modification, are permitted provided that the following conditions are met: # # . Redistributions of source code must retain the above copyright notice, this # list of conditions and the following disclaimer. # # . Redistributions in binary form must reproduce the above copyright notice, # this list of conditions and the following disclaimer in the documentation # and/or other materials provided with the distribution. # # . Neither the name of the "OpenWFE" nor the names of its contributors may be # used to endorse or promote products derived from this software without # specific prior written permission. # # THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" # AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE # IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE # ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE # LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR # CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF # SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS # INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN # CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) # ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE # POSSIBILITY OF SUCH DAMAGE. #++ # # $Id: definitions.rb 2725 2006-06-02 13:26:32Z jmettraux $ # # # "made in Japan" # # John Mettraux at openwfe.org # require 'openwfe/utils' require 'openwfe/rudefinitions' require 'openwfe/expressions/timeout' require 'openwfe/expressions/fe_utils' # # The participant expression, in its own file # module OpenWFE # # Participants sit at the edge between the engine and the external # world. The participant expression transmit the workitem applied # to it to the Participant instance it looks up in the participant map # tied to the engine. # class ParticipantExpression < FlowExpression include TimeoutMixin attr_accessor \ :participant_name, :applied_workitem # # apply / reply def apply (workitem) @applied_workitem = workitem.dup @participant_name = OpenWFE::lookup_ref(self, workitem) @participant_name = OpenWFE::fetch_text_content(self, workitem) \ unless @participant_name determine_timeout() reschedule(get_scheduler) store_itself() get_participant_map.dispatch(@participant_name, workitem) end #def reply (workitem) #end # # The cancel() method of a ParticipantExpression is particular : it # will emit a CancelItem instance towards the participant itself # to notify it of the cancellation. # def cancel wi = super() return wi unless @applied_workitem # # have to cancel the workitem on the participant side cancelitem = OpenWFE::CancelItem.new(@applied_workitem) get_participant_map.dispatch(@participant_name, cancelitem) return nil end # # Upon timeout, the ParticipantExpression will cancel itself and # the flow will resume. # def trigger (scheduler) ldebug { "trigger() timeout requested for #{@fei.to_debug_s}" } begin @scheduler_job_id = nil # # so that cancel won't unschedule without need cancel() reply_to_parent(@applied_workitem) rescue lerror do "trigger() problem while timing out\n"+ OpenWFE::exception_to_s($!) end end end end end