Module: TypedBus

Defined in:
lib/typed_bus.rb,
lib/typed_bus/stats.rb,
lib/typed_bus/channel.rb,
lib/typed_bus/version.rb,
lib/typed_bus/delivery.rb,
lib/typed_bus/message_bus.rb,
lib/typed_bus/configuration.rb,
lib/typed_bus/delivery_tracker.rb,
lib/typed_bus/dead_letter_queue.rb

Defined Under Namespace

Classes: Channel, Configuration, DeadLetterQueue, Delivery, DeliveryTracker, MessageBus, Stats

Constant Summary collapse

VERSION = 
"0.0.1"

Class Method Summary collapse

Class Method Details

.configuration ⇒ Configuration

The global Configuration instance.

Returns:



20
21
22
 
# File 'lib/typed_bus.rb', line 20

def configuration
  @configuration ||= Configuration.new
end

.configuration=(config) ⇒ Object

Replace the global Configuration.

Parameters:



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

def configuration=(config)
  @configuration = config
end

.configure {|configuration| ... } ⇒ Object

Yield the global Configuration for block-style setup.

Examples:

TypedBus.configure do |config|
  config.timeout = 60
  config.logger  = Logger.new($stdout)
end

Yields:



37
38
39
 
# File 'lib/typed_bus.rb', line 37

def configure
  yield configuration
end

.logger ⇒ Logger?

Shortcut — read the global logger.

Returns:

  • (Logger, nil) 


48
49
50
 
# File 'lib/typed_bus.rb', line 48

def logger
  configuration.logger
end

.logger=(log) ⇒ Object

Shortcut — set the global logger.

Parameters:

  • log (Logger, nil) 


54
55
56
 
# File 'lib/typed_bus.rb', line 54

def logger=(log)
  configuration.logger = log
end

.reset_configuration! ⇒ Object

Restore factory defaults (useful in tests).



42
43
44
 
# File 'lib/typed_bus.rb', line 42

def reset_configuration!
  @configuration = Configuration.new
end