Contents

# encoding: utf-8

$: << File.expand_path('../../lib', __FILE__)

require 'bundler/setup'
require 'mikka'


class Worker < Mikka::Actor
  def receive(message)
    puts "#{context.uuid} Work on #{message}"
  end
end

balancer = Mikka.load_balancer(:type => Worker, :count => 4)

10.times do |i|
  balancer << "item #{i}"
end

balancer << Mikka::Messages.broadcast("a message to everyone")

Mikka.registry.shutdown_all

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
mikka-1.1.1-java	examples/load_balancing2.rb
mikka-1.1.0-java	examples/load_balancing2.rb
mikka-1.0.1-java	examples/load_balancing2.rb
mikka-1.0.0-universal-darwin-11	examples/load_balancing2.rb