Module Beetle
In: lib/beetle/base.rb
lib/beetle/client.rb
lib/beetle/commands/configuration_client.rb
lib/beetle/commands/configuration_server.rb
lib/beetle/commands.rb
lib/beetle/configuration.rb
lib/beetle/deduplication_store.rb
lib/beetle/handler.rb
lib/beetle/logging.rb
lib/beetle/message.rb
lib/beetle/publisher.rb
lib/beetle/r_c.rb
lib/beetle/redis_configuration_client.rb
lib/beetle/redis_configuration_server.rb
lib/beetle/redis_master_file.rb
lib/beetle/redis_server_info.rb
lib/beetle/subscriber.rb
lib/beetle.rb

Methods

config  

Classes and Modules

Module Beetle::Commands
Module Beetle::Logging
Class Beetle::Base
Class Beetle::Client
Class Beetle::Configuration
Class Beetle::ConfigurationError
Class Beetle::DeduplicationStore
Class Beetle::Error
Class Beetle::Handler
Class Beetle::Message
Class Beetle::NoRedisMaster
Class Beetle::Publisher
Class Beetle::RedisConfigurationClient
Class Beetle::RedisConfigurationServer
Class Beetle::RedisServerInfo
Class Beetle::Subscriber
Class Beetle::UnknownMessage
Class Beetle::UnknownQueue

Constants

EXCHANGE_CREATION_KEYS = [:auto_delete, :durable, :internal, :nowait, :passive]   AMQP options for exchange creation
QUEUE_CREATION_KEYS = [:passive, :durable, :exclusive, :auto_delete, :no_wait]   AMQP options for queue creation
QUEUE_BINDING_KEYS = [:key, :no_wait]   AMQP options for queue bindings
PUBLISHING_KEYS = [:key, :mandatory, :immediate, :persistent, :reply_to]   AMQP options for message publishing
SUBSCRIPTION_KEYS = [:ack, :key]   AMQP options for subscribing to queues

Public Class methods

config() {|config| ...}

returns the default configuration object and yields it if a block is given

[Source]

    # File lib/beetle.rb, line 41
41:   def self.config
42:     #:yields: config
43:     @config ||= Configuration.new
44:     block_given? ? yield(@config) : @config
45:   end

[Validate]