Contents

$: << 'akka'

require 'java'
require 'akka/akka-modules-1.0'

module Akka
  include_package 'akka.actor'
  include_package 'akka.dispatch'
end

class Actor < Akka::UntypedActor
  def self.spawn
    Akka::Actors.actorOf { new }.tap do |actor|
      actor.setDispatcher(Akka::Dispatchers.newThreadBasedDispatcher(actor))
      actor.start
    end
  end  
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
akka-0.0.5	lib/akka.rb
akka-0.0.4	lib/akka.rb
akka-0.0.3	lib/akka.rb
akka-0.0.2	lib/akka.rb
akka-0.0.1	lib/akka.rb