class Kinetic::Base
Public Class Methods
new()
click to toggle source
# File lib/kinetic/base.rb, line 45 def initialize logger.info "Kinetic #{Kinetic::VERSION}" logger.debug "Loading serializer #{config.serializer}" require "kinetic/serializers/#{config.serializer.downcase}" @serializer = Object.const_get("Kinetic::Serializers::#{config.serializer}") end
Private Instance Methods
after_fork_procs()
click to toggle source
# File lib/kinetic/base.rb, line 58 def after_fork_procs @after_fork_procs ||= [] end
direct()
click to toggle source
# File lib/kinetic/base.rb, line 54 def direct exchanges[:direct] ||= {} end
exchanges()
click to toggle source
# File lib/kinetic/base.rb, line 62 def exchanges @exchanges ||= {} end
timed_events()
click to toggle source
# File lib/kinetic/base.rb, line 66 def timed_events @timed_events ||= {} end