Method: OpenWFE::Extras::ActivityFeedService#call

Defined in:
lib/openwfe/extras/misc/activityfeed.rb

#call(channel, *args) ⇒ Object

This is the method call by the expression pool each time a workitem reaches a participant.



126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
# File 'lib/openwfe/extras/misc/activityfeed.rb', line 126

def call (channel, *args)

    #ldebug "call() c '#{channel}' entries count : #{@entries.size}"

    e = Entry.new

    e.participant_name = channel
    e.upon = args[0]
    e.workitem = args[1].dup
    e.updated = Time.now

    e.id = \
        "#{e.workitem.participant_name} - #{e.upon} " +
        "#{e.workitem.fei.workflow_instance_id}--" +
        "#{e.workitem.fei.expression_id}"

    @entries << e

    while @entries.length > @max_item_count
        @entries.delete_at 0
    end
end