SMILA/Documentation/Worker/PipelineProcessorWorker

Available since SMILA 0.9.0!

PipelineProcessingWorker (bundle org.eclipse.smila.processing.worker)

The PipelineProcessingWorker is a worker designed to process synchronous pipelines inside a asynchronous workflow. The worker in principal is independant of a dedicated pipeline processing implementation. However, in SMILA we use BPEL pipelines for synchronous workflows, so in common speech the worker is also called BPEL worker.

JavaDoc

This page gives only a rough overview of the service. Please refer to the JavaDoc for detailed information about the Java components.

Configuration

The PipelineProcessingWorker is configured via incoming task parameters. These parameters could have been set e.g. in a job definition.

Parameter	Description	Default value
pipelineName	name of the synchronous (BPEL) pipeline to execute	---
numberOfParallelRecords	number of records to be processed in parallel by the synchronous workflow	1

Sample job definition that sets the parameters:

{
  "name":"myJob",
  "parameters":{
    "pipelineName": "myBpelPipeline",
    "numberOfParallelRecords": "10",
    ...
   },
  "workflow":"myWorkflow"
}

PipelineProcessingWorker definition in workers.json

  { "name": "pipelineProcessingWorker",
     "parameters": [ "pipelineName" ],
     "input": [ 
         {  "name": "input",              
            "type": "recordBulks"
         } ],
     "output": [ 
         {  "name": "output",
            "type": "recordBulks",
            "modes": ["optional"]
         } ]             
  }