Class: SplitIoClient::SSE::NotificationProcessor

Inherits:
Object
  • Object
show all
Defined in:
lib/splitclient-rb/sse/notification_processor.rb

Instance Method Summary collapse

Constructor Details

#initialize(config, splits_worker, segments_worker) ⇒ NotificationProcessor

Returns a new instance of NotificationProcessor.



6
7
8
9
10
 
# File 'lib/splitclient-rb/sse/notification_processor.rb', line 6

def initialize(config, splits_worker, segments_worker)
  @config = config
  @splits_worker = splits_worker
  @segments_worker = segments_worker
end

Instance Method Details

#process(incoming_notification) ⇒ Object 



12
13
14
15
16
17
18
19
20
21
22
23
 
# File 'lib/splitclient-rb/sse/notification_processor.rb', line 12

def process(incoming_notification)
  case incoming_notification.data['type']
  when SSE::EventSource::EventTypes::SPLIT_UPDATE
    process_split_update(incoming_notification)
  when SSE::EventSource::EventTypes::SPLIT_KILL
    process_split_kill(incoming_notification)
  when SSE::EventSource::EventTypes::SEGMENT_UPDATE
    process_segment_update(incoming_notification)
  else
    @config.logger.error("Incorrect event type: #{incoming_notification}")
  end
end