Skip to content

Instantly share code, notes, and snippets.

@anb

anb/gist:1559159

Created Jan 4, 2012
Embed
What would you like to do?
class TaskParticipant < Ruote::StorageParticipant
def consume(workitem)
doc = workitem.to_h
doc.merge!(
'type' => 'workitems',
'_id' => to_id(doc['fei']),
'participant_name' => doc['participant_name'],
'wfid' => doc['fei']['wfid'])
doc['store_name'] = @store_name if @store_name
if workitem.lookup('params.options.continue_process')
reply_to_engine(workitem)
else
@context.storage.put(doc)
end
end
end
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
You can’t perform that action at this time.