Method: MessageBus::Backends::Base#initialize

Defined in:

lib/message_bus/backends/base.rb

#initialize(config = {}, max_backlog_size = 1000) ⇒ Base

Returns a new instance of Base.

Parameters:

• config (Hash) (defaults to: {}) —

  backend-specific configuration options; see the concrete class for details

• max_backlog_size (Integer) (defaults to: 1000) —

  the largest permitted size (number of messages) for per-channel backlogs; beyond this capacity, old messages will be dropped.

# File 'lib/message_bus/backends/base.rb', line 75

def initialize(config = {}, max_backlog_size = 1000); end