Class: RbEAI::RouterTask

Inherits:
Task
  • Object
show all
Defined in:
lib/rbeai/TasksLogic.rb

Overview

91,92 91,92

Instance Attribute Summary collapse

Attributes inherited from Task

#name, #size, #status, #wflow

Instance Method Summary collapse

Methods inherited from Task

#getItemsNext, #persist, #persistFtp, #persistStr

Constructor Details

#initialize(wflow, xmlFull, xmlDoc) ⇒ RouterTask

Returns a new instance of RouterTask.



92
93
94
95
 
# File 'lib/rbeai/TasksLogic.rb', line 92

def initialize(wflow, xmlFull, xmlDoc)
  @logic = RouterLogic.new(xmlDoc)
  super(wflow, xmlFull, xmlDoc)
end

Instance Attribute Details

#nextTask ⇒ Object

Returns the value of attribute nextTask.



88
89
90
 
# File 'lib/rbeai/TasksLogic.rb', line 88

def nextTask
  @nextTask
end

Instance Method Details

#doJob(resultQueueList, obj) ⇒ Object 



97
98
99
100
101
 
# File 'lib/rbeai/TasksLogic.rb', line 97

def doJob(resultQueueList, obj)
  task = @logic.enroute(obj)
  print task, "=> ", obj , "\n"
  resultQueueList[task].enq(obj) if task != nil
end

#initQueues ⇒ Object 



103
104
105
106
107
108
109
 
# File 'lib/rbeai/TasksLogic.rb', line 103

def initQueues()
  resultQueueList = Hash.new(0)
  @logic.destinations.each do | task, logic|
    resultQueueList[task] = Queue.new
  end
  return resultQueueList
end