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, MaxPayloadBytesExceeded, UnableToPersistMessageError

Class Method Summary collapse

.new(*args) ⇒ Object

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