Module: ActivePublisher::Async::InMemoryAdapter

Defined in:: lib/active_publisher/async/in_memory_adapter.rb,
lib/active_publisher/async/in_memory_adapter/async_queue.rb,
lib/active_publisher/async/in_memory_adapter/consumer_thread.rb

Defined Under Namespace

Classes: Adapter, AsyncQueue, ConsumerThread, UnableToPersistMessageError

Class Method Summary collapse

.new(*args) ⇒ Object

Class Method Details

.new(*args) ⇒ `Object`



10
11
12

# File 'lib/active_publisher/async/in_memory_adapter.rb', line 10

def self.new(*args)
  ::ActivePublisher::Async::InMemoryAdapter::Adapter.new(*args)
end