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

Class GlobalOnlyPayloadReducer

java.lang.Object

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

All Implemented Interfaces:

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

public class GlobalOnlyPayloadReducer
extends Object
implements PayloadReducer

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

Since:

5.4.0

Author:

Simon Zambrovski

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
GlobalOnlyPayloadReducer()

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 GlobalOnlyPayloadReducer reducer.

See Also:

• Constant Field Values

INSTANCE

public static final GlobalOnlyPayloadReducer INSTANCE

Singleton instance of GlobalOnlyPayloadReducer.

Constructor Details

GlobalOnlyPayloadReducer

public GlobalOnlyPayloadReducer()

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.