Contents

Wukong.processor(:string_reverser) do

  def setup
    log.info("Inside the setup method")
    @count = 0
    EM.add_periodic_timer(10){ notify('metrics', count: @count) }
  end

  def process(record) 
    @count += 1
    yield record.reverse
    yield nil
  end

  def finalize
    log.info("Finalizing flow")
  end
  
  def stop
    log.info("Inside the stop method")
  end

end

Version data entries

6 entries across 6 versions & 2 rubygems

Version	Path
ul-wukong-4.1.1	examples/basic/string_reverser.rb
ul-wukong-4.1.0	examples/basic/string_reverser.rb
wukong-4.0.0	examples/basic/string_reverser.rb
wukong-3.0.1	examples/basic/string_reverser.rb
wukong-3.0.0	examples/basic/string_reverser.rb
wukong-3.0.0.pre3	examples/basic/string_reverser.rb