Module: Emque::Consuming

Defined in:
lib/emque/consuming.rb,
lib/emque/consuming/cli.rb,
lib/emque/consuming/core.rb,
lib/emque/consuming/actor.rb,
lib/emque/consuming/tasks.rb,
lib/emque/consuming/router.rb,
lib/emque/consuming/runner.rb,
lib/emque/consuming/status.rb,
lib/emque/consuming/adapter.rb,
lib/emque/consuming/control.rb,
lib/emque/consuming/helpers.rb,
lib/emque/consuming/logging.rb,
lib/emque/consuming/message.rb,
lib/emque/consuming/pidfile.rb,
lib/emque/consuming/version.rb,
lib/emque/consuming/consumer.rb,
lib/emque/consuming/consuming.rb,
lib/emque/consuming/application.rb,
lib/emque/consuming/transmitter.rb,
lib/emque/consuming/configuration.rb,
lib/emque/consuming/error_tracker.rb,
lib/emque/consuming/control/errors.rb,
lib/emque/consuming/consumer/common.rb,
lib/emque/consuming/control/workers.rb,
lib/emque/consuming/retryable_errors.rb,
lib/emque/consuming/adapters/rabbit_mq.rb,
lib/emque/consuming/command_receivers/base.rb,
lib/emque/consuming/generators/application.rb,
lib/emque/consuming/adapters/rabbit_mq/worker.rb,
lib/emque/consuming/adapters/rabbit_mq/manager.rb,
lib/emque/consuming/command_receivers/http_server.rb,
lib/emque/consuming/command_receivers/unix_socket.rb,
lib/emque/consuming/adapters/rabbit_mq/error_worker.rb,
lib/emque/consuming/adapters/rabbit_mq/delayed_message_worker.rb

Defined Under Namespace

Modules: Actor, Adapters, Application, CommandReceivers, Core, Generators, Helpers, Logging, RetryableErrors, Transmitter Classes: Adapter, AdapterConfigurationError, BlockingFailure, Cli, Configuration, ConfigurationError, Consumer, Control, ErrorTracker, Message, Pidfile, Router, Runner, Status, Tasks

Constant Summary collapse

VERSION = 
"1.7.0"

Class Attribute Summary collapse

Class Method Summary collapse

Class Attribute Details

.application ⇒ Object

Returns the value of attribute application.



7
8
9
 
# File 'lib/emque/consuming/consuming.rb', line 7

def application
  @application
end

Class Method Details

.config ⇒ Object

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



10
11
12
 
# File 'lib/emque/consuming/consuming.rb', line 10

def config
  Emque::Consuming.application.config
end

.consumer ⇒ Object 



5
6
7
8
9
10
11
12
 
# 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 ⇒ Object 



14
15
16
 
# File 'lib/emque/consuming/consuming.rb', line 14

def logger
  Emque::Consuming::Logging.logger
end

.logger=(log) ⇒ Object 



18
19
20
 
# File 'lib/emque/consuming/consuming.rb', line 18

def logger=(log)
  Emque::Consuming::Logging.logger = log
end

.runner ⇒ Object 



22
23
24
 
# File 'lib/emque/consuming/consuming.rb', line 22

def runner
  Emque::Consuming::Runner.instance
end