Class: Pubsub::DomainEventProcessor

Inherits:
Object
  • Object
show all
Defined in:
lib/pubsub/domain_event_processor.rb

Direct Known Subclasses

MultiThreadedDomainEventProcessor

Instance Method Summary collapse

Constructor Details

#initialize(domain_event_listener, serializer, logger) ⇒ DomainEventProcessor

Returns a new instance of DomainEventProcessor.



3
4
5
6
7
8
 
# File 'lib/pubsub/domain_event_processor.rb', line 3

def initialize(domain_event_listener, serializer, logger)
  @domain_event_listener = domain_event_listener
  @serializer = serializer
  @logger = logger
  @subscribers = []
end

Instance Method Details

#<<(subscriber) ⇒ Object 



10
11
12
 
# File 'lib/pubsub/domain_event_processor.rb', line 10

def <<(subscriber)
  @subscribers << subscriber
end

#listen_and_process_events ⇒ Object 



14
15
16
17
18
 
# File 'lib/pubsub/domain_event_processor.rb', line 14

def listen_and_process_events
  @domain_event_listener.listen do |message|
    broadcast(message)
  end
end