Package ai.mindconnect.workflow.jackson

Class JacksonWorkflowDefinitionRegistry

java.lang.Object

ai.mindconnect.workflow.jackson.JacksonWorkflowDefinitionRegistry

All Implemented Interfaces:

WorkflowDefinitionRegistry

public class JacksonWorkflowDefinitionRegistry
extends Object
implements WorkflowDefinitionRegistry

A WorkflowDefinitionRegistry that lazily loads workflow definitions from JSON files on the classpath.

Workflows are stored under a configurable base directory (default: /workflows) as <workflowId>.json. Definitions loaded from the classpath are cached so each file is only parsed once.

Programmatically registered definitions (via putWorkflowDefinition(java.lang.String, ai.mindconnect.workflow.domain.WorkflowData)) take precedence over classpath files.

Example classpath layout:

 src/main/resources/
   workflows/
     my_import_flow.json
     my_query_flow.json
 

Then: registry.getWorkflowDefinition("my_import_flow") loads and caches /workflows/my_import_flow.json.

Constructor Summary

Constructors

Constructor	Description
JacksonWorkflowDefinitionRegistry(JacksonWorkflowSerializer serializer)	Creates a registry that scans the default /workflows classpath directory.
JacksonWorkflowDefinitionRegistry(JacksonWorkflowSerializer serializer, String baseDir)	Creates a registry that scans the given classpath directory.

Method Summary

Modifier and Type	Method	Description
WorkflowData	getWorkflowDefinition(String workflowId)
void	putWorkflowDefinition(String id, WorkflowData workflowData)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

JacksonWorkflowDefinitionRegistry

public JacksonWorkflowDefinitionRegistry(JacksonWorkflowSerializer serializer)

Creates a registry that scans the default /workflows classpath directory.

JacksonWorkflowDefinitionRegistry

public JacksonWorkflowDefinitionRegistry(JacksonWorkflowSerializer serializer,
 String baseDir)

Creates a registry that scans the given classpath directory.

Parameters:

serializer - the serializer used to parse JSON files

baseDir - classpath-relative directory, e.g. /workflows

Method Details

getWorkflowDefinition

public WorkflowData getWorkflowDefinition(String workflowId)

Specified by:

getWorkflowDefinition in interface WorkflowDefinitionRegistry

putWorkflowDefinition

public void putWorkflowDefinition(String id,
 WorkflowData workflowData)

Specified by:

putWorkflowDefinition in interface WorkflowDefinitionRegistry