module Asynk

booted_inside=(value) click to toggle source

# File lib/asynk.rb, line 59
def booted_inside=(value)
  @booted_inside = value
end

booted_inside?() click to toggle source

# File lib/asynk.rb, line 57
def booted_inside?; @booted_inside; end

broker() click to toggle source

# File lib/asynk.rb, line 55
def broker; Broker; end

config() click to toggle source

# File lib/asynk.rb, line 63
def config; Config.instance; end

consumers() click to toggle source

# File lib/asynk.rb, line 31
def consumers
  @consumers ||= []
end

logger() click to toggle source

# File lib/asynk.rb, line 43
def logger
  Asynk::Logging.logger
end

logger=(log) click to toggle source

# File lib/asynk.rb, line 47
def logger=(log)
  Asynk::Logging.logger = log
end

options() click to toggle source

# File lib/asynk.rb, line 35
def options
  @options ||= DEFAULTS.dup
end

options=(opts) click to toggle source

# File lib/asynk.rb, line 39
def options=(opts)
  @options = opts
end

register_consumer(consumer) click to toggle source

# File lib/asynk.rb, line 26
def register_consumer(consumer)
  return if Asynk.config[:ignored_consumers].include? consumer.name
  self.consumers << consumer
end

server() click to toggle source

# File lib/asynk.rb, line 51
def server
  Server.instance
end

Constants

Public Class Methods