Class: Kinetic::Base

Inherits:
Object
  • Object
show all
Extended by:
DSL
Defined in:
lib/kinetic/base.rb

Direct Known Subclasses

Application

Class Method Summary collapse

Instance Method Summary collapse

Methods included from DSL

after_fork, logger, on_direct

Methods included from DSL::Configuration

#config, #config_file, #set

Constructor Details

#initialize ⇒ Base

Returns a new instance of Base.



70
71
72
 
# File 'lib/kinetic/base.rb', line 70

def initialize
  self.class.send(:set_serializer, config.serializer)
end

Class Method Details

.after_fork_procs ⇒ Object 



44
45
46
 
# File 'lib/kinetic/base.rb', line 44

def after_fork_procs
  @after_fork_procs ||= []
end

.deserialize(message) ⇒ Object 



52
53
54
 
# File 'lib/kinetic/base.rb', line 52

def deserialize(message)
  @serializer.deserialize(message)
end

.exchanges ⇒ Object 



48
49
50
 
# File 'lib/kinetic/base.rb', line 48

def exchanges
  @exchanges ||= {}
end