sample_app.rb

require "concurrent/actor"

class SampleApp < Concurrent::Actor::Context

  private_class_method :spawn, :spawn!

  def self.run!
    spawn!(:sample_app)
  end

  def initialize
    @manager = EventSourcing::Aggregate::Manager.spawn!(name: :aggregate_manager, supervise: true, behaviour: Behaviour.restarting_behaviour)
  end

  def on_message(message)
    case message
    when :manager
      @manager
    end
  end

  def default_reference_class
    Reference
  end

  class Reference < Concurrent::Actor::Reference
    def manager
      ask(:manager).value
    end
  end
end