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