test.rb

$:File
.expand'_path
('../lib',
  __FILE__)
require
'floss/node'[ CLUSTER_SIZE = 5 ]
[ nodes = CLUSTER_SIZE.times.map ]
do 
|i|port =  5000
0 + i "tcp://127.0.0.1:#{port}"
endsupervisor=Celluloid::Supervision
Group.run 
!CLUSTER_SIZE.times.map 
do |i|  combinationodes
.rotate(i) options={id:combination
.first, 
peers: combination
[1..-1]}supervisor.supervise(Floss::Node, options)
end sleep 1  begin leader=supervisor
.actors
.find
(&:leader?) 
puts
"The leader is #{leader.id}"
leader.execute
("Hello World!")rescue => e puts "Could
not execute my command!"pendsleep 1 begin
  leader = supervisor.actors.find
  (&:leader?)puts "The leader is 
  #{leader.id}" leader.execute
  (
  "Hello Again!"
  ) rescue => e 
puts "Could execute my command!"
  pend sleep 0.5
supervisor.actors
.each do |actor| Celluloid.logger.info("Log of #{actor.id}: #{actor.log.entries}")end
sleep 1 exit