Class: Ecco::RowEventListener

Inherits:
EventListener show all
Defined in:
lib/ecco/row_event_listener.rb

Constant Summary collapse

ROW_EVENTS = 
[
  EventType::WRITE_ROWS,
  EventType::UPDATE_ROWS,
  EventType::DELETE_ROWS,
]

Instance Attribute Summary

Attributes inherited from EventListener

#callback

Instance Method Summary collapse

Methods inherited from EventListener

#initialize

Constructor Details

This class inherits a constructor from Ecco::EventListener

Instance Method Details

#accepted_events ⇒ Object 



16
17
18
 
# File 'lib/ecco/row_event_listener.rb', line 16

def accepted_events
  ROW_EVENTS
end

#on_event(event) ⇒ Object 



20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
 
# File 'lib/ecco/row_event_listener.rb', line 20

def on_event(event)
  data = event.get_data
  type = event.get_header.get_event_type

  case type
  when table_event
    @table_map_event = event
  when *accepted_events
    row_event          = Ecco::RowEvent.new
    row_event.type     = type.to_s
    row_event.table_id = data.get_table_id
    row_event.rows     = data.rows

    if @table_map_event
      table_event_data = @table_map_event.get_data

      row_event.database = table_event_data.get_database
      row_event.table    = table_event_data.get_table
    end

    @callback.call(row_event)
  end
end

#table_event ⇒ Object 



12
13
14
 
# File 'lib/ecco/row_event_listener.rb', line 12

def table_event
  EventType::TABLE_MAP
end