Package io.axoniq.framework.workflow.runtime.execution.payload

Class LocalOnlyPayloadReducer

java.lang.Object

io.axoniq.framework.workflow.runtime.execution.payload.LocalOnlyPayloadReducer

All Implemented Interfaces:

PayloadReducer, BiFunction<Map<String,@Nullable Object>,Map<String,@Nullable Object>,Map<String,@Nullable Object>>

public class LocalOnlyPayloadReducer
extends Object
implements PayloadReducer

Simple PayloadReducer that will only pass along the local payload, ignoring the global payload, without modification.

Since:

5.4.0

Author:

Simon Zambrovski

Field Summary

Fields

Modifier and Type	Field	Description
static final LocalOnlyPayloadReducer	INSTANCE	Singleton instance of LocalOnlyPayloadReducer.
static final String	NAME	Name of LocalOnlyPayloadReducer reducer.

Constructor Summary

Constructors

Constructor	Description
LocalOnlyPayloadReducer()

Method Summary

Modifier and Type	Method	Description
Map<String,@Nullable Object>	apply(Map<String,@Nullable Object> global, Map<String,@Nullable Object> local)
String	name()	Retrieves the name of the reducer.

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.BiFunction

andThen

Field Details

NAME

public static final String NAME

Name of LocalOnlyPayloadReducer reducer.

See Also:

• Constant Field Values

INSTANCE

public static final LocalOnlyPayloadReducer INSTANCE

Singleton instance of LocalOnlyPayloadReducer.

Constructor Details

LocalOnlyPayloadReducer

public LocalOnlyPayloadReducer()

Method Details

apply

public Map<String,@Nullable Object> apply(Map<String,@Nullable Object> global,
 Map<String,@Nullable Object> local)

Specified by:

apply in interface BiFunction<Map<String,@Nullable Object>,Map<String,@Nullable Object>,Map<String,@Nullable Object>>

name

public String name()

Description copied from interface: PayloadReducer

Retrieves the name of the reducer.

Specified by:

name in interface PayloadReducer

Returns:

reducer name.