Contents

# encoding: utf-8

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

require 'bundler/setup'
require 'mikka'


worker1 = Mikka.actor { |msg| puts "Worker 1 working on #{msg}" }
worker2 = Mikka.actor { |msg| puts "Worker 2 working on #{msg}" }
balancer = Mikka.load_balancer(:actors => [worker1, worker2])

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

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

Mikka.registry.shutdown_all

Version data entries

4 entries across 4 versions & 1 rubygems

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