Uses of Interface
io.axoniq.framework.workflow.dsl.api.PayloadReducer
Packages that use PayloadReducer
Package
Description
Internal runtime contracts for workflow execution, command dispatch, configuration, and event publication.
PayloadReducer implementations and their registry, combining or selecting between the global (workflow
context) and local payloads passed to and returned from workflow steps.-
Uses of PayloadReducer in io.axoniq.framework.workflow.dsl.api
Methods in io.axoniq.framework.workflow.dsl.api that return PayloadReducerModifier and TypeMethodDescriptionPayloadMapping.parameterPayloadReducer()Returns the value of theparameterPayloadReducerrecord component.PayloadMapping.resultPayloadReducer()Returns the value of theresultPayloadReducerrecord component.Methods in io.axoniq.framework.workflow.dsl.api with parameters of type PayloadReducerModifier and TypeMethodDescriptionExecuteStepDefinition.parameterPayloadReducer(PayloadReducer parameterPayloadReducer) Returns a copy of this definition with the provided parameter payload reducer.PayloadMapping.parameterPayloadReducer(PayloadReducer parameterPayloadReducer) Returns a copy of this mapping with the provided parameter payload reducer.ExecuteStepDefinition.resultPayloadReducer(PayloadReducer resultPayloadReducer) Returns a copy of this definition with the provided result payload reducer.PayloadMapping.resultPayloadReducer(PayloadReducer resultPayloadReducer) Returns a copy of this mapping with the provided result payload reducer.WaitForStepDefinition.resultPayloadReducer(PayloadReducer resultPayloadReducer) Returns a copy of this definition with the provided result payload reducer.Constructors in io.axoniq.framework.workflow.dsl.api with parameters of type PayloadReducerModifierConstructorDescriptionPayloadMapping(PayloadReducer parameterPayloadReducer, PayloadReducer resultPayloadReducer) Creates an instance of aPayloadMappingrecord class. -
Uses of PayloadReducer in io.axoniq.framework.workflow.runtime.api.execution.context
Methods in io.axoniq.framework.workflow.runtime.api.execution.context that return PayloadReducerModifier and TypeMethodDescriptionPrimitiveCommands.WorkflowStepResultExecuteCommand.parameterMapping()Returns the value of theparameterMappingrecord component.ExecutePrimitive.ExecuteCommand.parameterPayloadReducer()Returns reducer to be used for the step parameters.PrimitiveCommands.WorkflowStepResultExecuteCommand.parameterPayloadReducer()PrimitiveCommands.WorkflowStepResultExecuteCommand.resultMapping()Returns the value of theresultMappingrecord component.ExecutePrimitive.ExecuteCommand.resultPayloadReducer()Returns reducer to be used for the step result.PrimitiveCommands.WorkflowStepResultExecuteCommand.resultPayloadReducer()PrimitiveCommands.WorkflowStepResultWaitForCommand.resultPayloadReducer()Returns the value of theresultPayloadReducerrecord component.WaitForPrimitive.WaitForCommand.resultPayloadReducer()Returns the result payload reducer.Methods in io.axoniq.framework.workflow.runtime.api.execution.context with parameters of type PayloadReducerModifier and TypeMethodDescriptionPrimitiveCommands.waitForEvent(String stepName, EventCondition eventCondition, PayloadReducer resultPayloadReducer, Duration duration, EventNameCustomizer eventNameCustomizer) Factory method to create aPrimitiveCommands.WorkflowStepResultWaitForCommand.Constructors in io.axoniq.framework.workflow.runtime.api.execution.context with parameters of type PayloadReducerModifierConstructorDescriptionWorkflowStepResultExecuteCommand(String stepName, Map<String, @Nullable Object> local, PayloadProcessor action, PayloadReducer parameterMapping, PayloadReducer resultMapping, Duration timeout, EventNameCustomizer eventNameCustomizer, RetryPolicy retryPolicy) Creates an instance of aWorkflowStepResultExecuteCommandrecord class.WorkflowStepResultWaitForCommand(String stepName, EventCondition eventCondition, PayloadReducer resultPayloadReducer, Duration timeout, EventNameCustomizer eventNameCustomizer) Creates an instance of aWorkflowStepResultWaitForCommandrecord class. -
Uses of PayloadReducer in io.axoniq.framework.workflow.runtime.execution.payload
Classes in io.axoniq.framework.workflow.runtime.execution.payload that implement PayloadReducerModifier and TypeClassDescriptionclassCombines two payloads into one.classSimplePayloadReducerthat will only pass along theglobalpayload, ignoring thelocalpayload, without modification.classSimplePayloadReducerthat will only pass along thelocalpayload, ignoring theglobalpayload, without modification.Methods in io.axoniq.framework.workflow.runtime.execution.payload that return types with arguments of type PayloadReducerModifier and TypeMethodDescriptionRetrieves a payload reducer by name.Methods in io.axoniq.framework.workflow.runtime.execution.payload with parameters of type PayloadReducerModifier and TypeMethodDescriptionvoidPayloadReducerRegistry.register(PayloadReducer reducer) Registers new payload reducer.