Class: Mode::Connector::Processor

Inherits:
Object
  • Object
show all
Defined in:
lib/mode/connector/processor.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(message, data_sources) ⇒ Processor

Returns a new instance of Processor.



11
12
13
14
 
# File 'lib/mode/connector/processor.rb', line 11

def initialize(message, data_sources)
  @message = message
  @data_sources = data_sources
end

Instance Attribute Details

#data_sources ⇒ Object (readonly)

Returns the value of attribute data_sources.



9
10
11
 
# File 'lib/mode/connector/processor.rb', line 9

def data_sources
  @data_sources
end

#message ⇒ Object (readonly)

Returns the value of attribute message.



8
9
10
 
# File 'lib/mode/connector/processor.rb', line 8

def message
  @message
end

Instance Method Details

#perform! ⇒ Object 



16
17
18
19
20
21
22
23
24
25
26
27
 
# File 'lib/mode/connector/processor.rb', line 16

def perform!
  if data_source
    send!(select!)
  else
    raise "Data source not found #{message.data_source.name}"
  end
rescue => err
  error!(err.message, err.backtrace.join("\n"))
  
  Mode::Logger.instance.error(
    "Connector::Processor", err.message, err.backtrace)
end