# File lib/nanite/cluster.rb, line 5 def initialize(amq, agent_timeout, identity, serializer, mapper, state_configuration=nil, callbacks = {}) @amq = amq @agent_timeout = agent_timeout @identity = identity @serializer = serializer @mapper = mapper @state = state_configuration @security = SecurityProvider.get @callbacks = callbacks setup_state @reaper = Reaper.new(agent_timeout) setup_queues end