Module: MessageDriver

Defined in:
lib/message_driver.rb,
lib/message_driver/broker.rb,
lib/message_driver/client.rb,
lib/message_driver/errors.rb,
lib/message_driver/logging.rb,
lib/message_driver/message.rb,
lib/message_driver/version.rb,
lib/message_driver/middleware.rb,
lib/vendor/nesty/nested_error.rb,
lib/message_driver/destination.rb,
lib/message_driver/subscription.rb,
lib/message_driver/adapters/base.rb,
lib/message_driver/middleware/base.rb,
lib/message_driver/adapters/bunny_adapter.rb,
lib/message_driver/adapters/stomp_adapter.rb,
lib/message_driver/adapters/in_memory_adapter.rb,
lib/message_driver/middleware/block_middleware.rb,
lib/message_driver/middleware/middleware_stack.rb

Overview

Easy message queues for ruby

Defined Under Namespace

Modules: Adapters, Client, Destination, DontRequeue, Message, Middleware, Nesty, Subscription Classes: Broker, BrokerAlreadyConfigured, BrokerNotConfigured, ConnectionError, DontRequeueError, Error, NoSuchConsumerError, NoSuchDestinationError, QueueNotFound, TransactionError, TransactionRollbackOnly, WrappedDontRequeueError, WrappedError

Constant Summary collapse

VERSION =

Returns version of the library.

Returns:

  • (String) —

    version of the library

'1.0.1'.freeze

Class Attribute Summary collapse

Class Method Summary collapse

Class Attribute Details

.logger ⇒ Logger

defaults to an INFO level logger that logs to STDOUT

Returns:

  • (Logger) —

    the logger MessageDriver will use for logging.



26
27
28
 
# File 'lib/message_driver.rb', line 26

def logger
  @__logger ||= Logger.new(STDOUT).tap { |l| l.level = Logger::INFO }
end

Class Method Details

.configure(options) ⇒ Object .configure(name, options) ⇒ Object

Parameters:

  • name (Symbol) (defaults to: Broker::DEFAULT_BROKER_NAME) —

    when configuring multiple brokers, this symbol will differentiate between brokers

  • options (Hash) —

    options to be passed to the adapter class



19
20
21
 
# File 'lib/message_driver.rb', line 19

def configure(name = Broker::DEFAULT_BROKER_NAME, options)
  Broker.configure(name, options)
end