Package io.serverlessworkflow.impl.executors.func

Class JavaConsumerCallExecutor

java.lang.Object

io.serverlessworkflow.impl.executors.func.JavaConsumerCallExecutor

All Implemented Interfaces:

CallableTask<CallJava.CallJavaConsumer>

public class JavaConsumerCallExecutor
extends Object
implements CallableTask<CallJava.CallJavaConsumer>

Constructor Summary

Constructors

Constructor	Description
JavaConsumerCallExecutor()

Method Summary

Modifier and Type	Method	Description
boolean	accept(Class<? extends io.serverlessworkflow.api.types.TaskBase> clazz)
CompletableFuture<WorkflowModel>	apply(WorkflowContext workflowContext, TaskContext taskContext, WorkflowModel input)
void	init(CallJava.CallJavaConsumer task, io.serverlessworkflow.api.types.Workflow workflow, WorkflowApplication application, ResourceLoader loader)

Methods inherited from class java.lang.Object

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

Constructor Details

JavaConsumerCallExecutor

public JavaConsumerCallExecutor()

Method Details

init

public void init(CallJava.CallJavaConsumer task,
 io.serverlessworkflow.api.types.Workflow workflow,
 WorkflowApplication application,
 ResourceLoader loader)

Specified by:

init in interface CallableTask<CallJava.CallJavaConsumer>

apply

public CompletableFuture<WorkflowModel> apply(WorkflowContext workflowContext,
 TaskContext taskContext,
 WorkflowModel input)

Specified by:

apply in interface CallableTask<CallJava.CallJavaConsumer>

accept

public boolean accept(Class<? extends io.serverlessworkflow.api.types.TaskBase> clazz)

Specified by:

accept in interface CallableTask<CallJava.CallJavaConsumer>