module Emque::Consuming

Constants

VERSION

Attributes

application[RW]

Public Class Methods

config() click to toggle source

The Configuration instance used to configure the Emque::Consuming environment

# File lib/emque/consuming/consuming.rb, line 10
def config
  Emque::Consuming.application.config
end
consumer() click to toggle source
# File lib/emque/consuming/consumer/common.rb, line 5
def self.consumer
  Module.new do
    define_singleton_method(:included) do |descendant|
      descendant.send(:include, ::Pipe)
      descendant.send(:include, ::Emque::Consuming::Consumer::Common)
    end
  end
end
logger() click to toggle source
# File lib/emque/consuming/consuming.rb, line 14
def logger
  Emque::Consuming::Logging.logger
end
logger=(log) click to toggle source
# File lib/emque/consuming/consuming.rb, line 18
def logger=(log)
  Emque::Consuming::Logging.logger = log
end
runner() click to toggle source
# File lib/emque/consuming/consuming.rb, line 22
def runner
  Emque::Consuming::Runner.instance
end