Class: Floe::Workflow::ItemProcessor

Inherits:

Floe::WorkflowBase

• Object
• Floe::WorkflowBase
• Floe::Workflow::ItemProcessor

Defined in:

lib/floe/workflow/item_processor.rb

Instance Attribute Summary

• #processor_config ⇒ Object readonly

  Returns the value of attribute processor_config.

Attributes inherited from Floe::WorkflowBase

#name, #payload, #start_at, #states, #states_by_name

Instance Method Summary

• #initialize(payload, name = nil) ⇒ ItemProcessor constructor

  A new instance of ItemProcessor.

Methods inherited from Floe::WorkflowBase

#current_state, #end?, #output, #run, #run_nonblock, #start_workflow, #step_nonblock, #step_nonblock_ready?, #wait_until, #waiting?

Methods included from ValidationMixin

included, #invalid_field_error!, #missing_field_error!, #parser_error!, #runtime_field_error!, #workflow_state?, #wrap_parser_error

Constructor Details

#initialize(payload, name = nil) ⇒ ItemProcessor

Returns a new instance of ItemProcessor.

# File 'lib/floe/workflow/item_processor.rb', line 8

def initialize(payload, name = nil)
  super
  @processor_config = payload.fetch("ProcessorConfig", "INLINE")
end

Instance Attribute Details

#processor_config ⇒ Object (readonly)

Returns the value of attribute processor_config.

# File 'lib/floe/workflow/item_processor.rb', line 6

def processor_config
  @processor_config
end