Notice: this Wiki will be going read only early in 2024 and edits will no longer be possible. Please see: https://gitlab.eclipse.org/eclipsefdn/helpdesk/-/wikis/Wiki-shutdown-plan for the plan.
Difference between revisions of "SMILA/Specifications/RecordWorkflowDiscussion09"
< SMILA | Specifications
(New page: =Problems= # it's wanted to have ability to filter record in Router/Listener before starting any operations # it's wanted to configure ODEWorkflowProcessor with record-filter used. == W...) |
|||
| Line 16: | Line 16: | ||
... | ... | ||
} | } | ||
| − | <source> | + | </source> |
ODEWorkflowProcessor implementation is reading property "record.filter" from it's own configuration file and filtering all records before processing with only one filter. | ODEWorkflowProcessor implementation is reading property "record.filter" from it's own configuration file and filtering all records before processing with only one filter. | ||
| Line 31: | Line 31: | ||
... | ... | ||
} | } | ||
| − | <source> | + | </source> |
Or | Or | ||
| Line 41: | Line 41: | ||
... | ... | ||
} | } | ||
| − | <source> | + | </source> |
Revision as of 11:00, 17 November 2008
Problems
- it's wanted to have ability to filter record in Router/Listener before starting any operations
- it's wanted to configure ODEWorkflowProcessor with record-filter used.
WorkflowProcessor
Problems
Now WorkflowProcessor API accepts series of Ids only for starting pipelines.
public interface WorkflowProcessor { ... Id[] process(String workflowName, Id[] recordIds) throws ProcessingException; ... }
ODEWorkflowProcessor implementation is reading property "record.filter" from it's own configuration file and filtering all records before processing with only one filter.
Suggested
To configure record filter in Router/Listener rules
WorkflowProcessor public API should accepts record or Id + filterName.
public interface WorkflowProcessor { ... void process(String workflowName, record) throws ProcessingException; ... }
Or
public interface WorkflowProcessor { ... void process(String workflowName, Id id, filterName) throws ProcessingException; ... }