Class: GameMachine::Scheduler

Inherits:
Actor::Base
  • Object
show all
Defined in:
lib/game_machine/scheduler.rb

Constant Summary

Constants inherited from Actor::Base

Actor::Base::ON_RECEIVE_HOOKS

Instance Method Summary collapse

Methods inherited from Actor::Base

aspect, aspects, find, find_by_address, find_distributed, find_distributed_local, find_remote, hashring, local_path, model_filter, #onReceive, player_controller, #receive_message, #schedule_message, #sender, set_player_controller

Instance Method Details

#on_receive(message) ⇒ Object



15
16
17
18
19
20
# File 'lib/game_machine/scheduler.rb', line 15

def on_receive(message)
  if message == 'every_10_seconds'
    #GameMachine.logger.debug "Cluster members #{ClusterMonitor.cluster_members.keys.to_a.inspect}"
    #GameMachine.logger.debug "Hashrings #{Akka.instance.hashring.nodes.inspect}"
  end
end

#preStartObject



4
5
6
7
8
9
10
11
12
13
# File 'lib/game_machine/scheduler.rb', line 4

def preStart
  scheduler = get_context.system.scheduler
  dispatcher = get_context.system.dispatcher

  every_second = JavaLib::Duration.create(1, java.util.concurrent.TimeUnit::SECONDS)
  #scheduler.schedule(every_second, every_second, get_self, "every_second", dispatcher, nil)

  every_10_seconds = JavaLib::Duration.create(10, java.util.concurrent.TimeUnit::SECONDS)
  #scheduler.schedule(every_10_seconds, every_10_seconds, get_self, "every_10_seconds", dispatcher, nil)
end