Module: ActivePublisher::Async::InMemoryAdapter

Defined in:
lib/active_publisher/async/in_memory_adapter.rb,
lib/active_publisher/async/in_memory_adapter/channel.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, Channel, ConsumerThread, UnableToPersistMessageError

Class Method Summary collapse

Class Method Details

.new(*args) ⇒ Object



12
13
14
# File 'lib/active_publisher/async/in_memory_adapter.rb', line 12

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