Contents

$:.unshift File.dirname(__FILE__)+"/../../lib/"
require 'magent'

Magent.push("stats", :calc)
Magent.push("stats", :calc)
Magent.push("stats", :calc)
Magent.push("stats", :calc)

class Stats
  include Magent::Actor

  channel_name "stats"
  expose :calc

  def calc(payload)
    $stderr.puts "messages in queue: #{self.class.channel.queue_count}"
    $stderr.puts "total messages count: #{self.class.channel.message_count}"
    $stderr.puts "total errors: #{self.class.channel.error_count}"
  end
end

Magent.register(Stats.new)

if $0 == __FILE__
  Magent::Processor.new(Stats.channel).run!
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
magent-0.6.2	examples/stats/stats.rb
magent-0.6.1	examples/stats/stats.rb
magent-0.6.0	examples/stats/stats.rb
magent-0.5.4	examples/stats/stats.rb
magent-0.5.3	examples/stats/stats.rb
magent-0.5.2	examples/stats/stats.rb
magent-0.5.1	examples/stats/stats.rb
magent-0.5.0	examples/stats/stats.rb