Class: CDC::Concurrent::Router

Inherits:
Object
  • Object
show all
Defined in:
lib/cdc/concurrent/router.rb

Overview

Routes CDC work items to the correct concurrent pool.

Instance Method Summary collapse

Constructor Details

#initialize(processor_pool:, transaction_pool:) ⇒ Router

Returns a new instance of Router.

Parameters:



9
10
11
12
 
# File 'lib/cdc/concurrent/router.rb', line 9

def initialize(processor_pool:, transaction_pool:)
  @processor_pool = processor_pool
  @transaction_pool = transaction_pool
end

Instance Method Details

#process(item) ⇒ Object

Parameters:

  • item (Object)

Returns:

  • (Object) 


16
17
18
19
20
21
22
23
24
25
26
27
 
# File 'lib/cdc/concurrent/router.rb', line 16

def process(item)
  case item
  when CDC::Core::ChangeEvent
    @processor_pool.process(item)
  when CDC::Core::TransactionEnvelope
    @transaction_pool.process(item)
  when Array
    @processor_pool.process_many(item)
  else
    raise UnsupportedWorkItemError, "unsupported CDC work item: #{item.class}"
  end
end