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

Class PayloadReducerRegistry

java.lang.Object

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

public class PayloadReducerRegistry
extends Object

Registry of payload reducers defined by PayloadReducer.

Since:

5.4.0

Author:

Simon Zambrovski

Constructor Summary

Constructors

Constructor	Description
PayloadReducerRegistry()	Constructs a new registry and loads reducers.
PayloadReducerRegistry(boolean loadReducers, ClassLoader classLoader)	Constructs a new registry and loads reducers.

Method Summary

Modifier and Type	Method	Description
Optional<PayloadReducer>	get(String name)	Retrieves a payload reducer by name.
void	register(PayloadReducer reducer)	Registers new payload reducer.

Methods inherited from class java.lang.Object

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

Constructor Details

PayloadReducerRegistry

public PayloadReducerRegistry()

Constructs a new registry and loads reducers.

PayloadReducerRegistry

public PayloadReducerRegistry(boolean loadReducers,
 ClassLoader classLoader)

Constructs a new registry and loads reducers.

Parameters:

loadReducers - flag indicating if the Service loading of reducers should be performed.

classLoader - class loader to use for loading reducers.

Method Details

register

public void register(PayloadReducer reducer)

Registers new payload reducer.

Parameters:

reducer - reducer to register.

get

public Optional<PayloadReducer> get(String name)

Retrieves a payload reducer by name.

Parameters:

name - name of the reducer.

Returns:

payload reducer.