Package com.opencqrs.framework.persistence

Interface EventReader.UpcastedCallback

Enclosing interface:

EventReader

public static interface EventReader.UpcastedCallback

Callback interface specifying operations to deal with an encapsulated upcasted Event.

Method Summary

Modifier and Type	Method	Description
void	convert(BiConsumer<Map<String,?>,Object> eventConsumer)	Converts the encapsulated Event to meta-data and a Java object of the type determined by getEventJavaClass() and maps it to the given consumer.
default void	convert(Consumer<Object> eventConsumer)	Converts the encapsulated Event to a Java object of the type determined by getEventJavaClass() and maps it to the given consumer.
Class<?>	getEventJavaClass()	Determines the Java Class for the encapsulated Event.

Method Details

getEventJavaClass

Class<?> getEventJavaClass()

Determines the Java Class for the encapsulated Event.

Returns:

the associated Java type

See Also:

• EventTypeResolver

convert

default void convert(Consumer<Object> eventConsumer)

Converts the encapsulated Event to a Java object of the type determined by getEventJavaClass() and maps it to the given consumer.

Parameters:

eventConsumer - consumer for the converted Java event object

See Also:

• EventTypeResolver
• EventDataMarshaller

convert

void convert(BiConsumer<Map<String,?>,Object> eventConsumer)

Converts the encapsulated Event to meta-data and a Java object of the type determined by getEventJavaClass() and maps it to the given consumer.

Parameters:

eventConsumer - bi-consumer for the meta-data map and the converted Java event object

See Also:

• EventTypeResolver
• EventDataMarshaller