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