Class: Pubsub::MultiThreadedDomainEventProcessor

Inherits:

DomainEventProcessor

• Object
• DomainEventProcessor
• Pubsub::MultiThreadedDomainEventProcessor

Defined in:

lib/pubsub/multithreaded_domain_event_processor.rb

Instance Method Summary

• #initialize(domain_event_listener, serializer, logger) ⇒ MultiThreadedDomainEventProcessor constructor

  A new instance of MultiThreadedDomainEventProcessor.

Methods inherited from DomainEventProcessor

#<<, #listen_and_process_events

Constructor Details

#initialize(domain_event_listener, serializer, logger) ⇒ MultiThreadedDomainEventProcessor

Returns a new instance of MultiThreadedDomainEventProcessor.

# File 'lib/pubsub/multithreaded_domain_event_processor.rb', line 5

def initialize(domain_event_listener, serializer, logger)
  super(domain_event_listener, serializer, logger)
  amount_of_threads = Concurrent.processor_count
  @thread_pool = Concurrent::FixedThreadPool.new(amount_of_threads)
end