org.axonframework.eventsourcing.eventstore

Class EventUtils

java.lang.Object

org.axonframework.eventsourcing.eventstore.EventUtils

public abstract class EventUtils
extends Object

Utility class for dealing with events and event streams.

Author:

Rene de Waele

Method Summary

Modifier and Type	Method and Description
static <T> DomainEventMessage<T>	asDomainEventMessage(EventMessage<T> eventMessage) Convert a plain EventMessage to a DomainEventMessage.
static Stream<? extends DomainEventMessage<?>>	asStream(DomainEventStream domainEventStream) Convert the given domainEventStream to a regular java Stream of domain event messages.
static <T> TrackedEventMessage<T>	asTrackedEventMessage(EventMessage<T> eventMessage, TrackingToken trackingToken) Convert an EventMessage to a TrackedEventMessage using the given trackingToken.
static DomainEventStream	upcastAndDeserializeDomainEvents(Stream<? extends DomainEventData<?>> eventEntryStream, Serializer serializer, EventUpcaster upcasterChain, boolean skipUnknownTypes) Upcasts and deserializes the given eventEntryStream using the given serializer and upcasterChain.
static Stream<TrackedEventMessage<?>>	upcastAndDeserializeTrackedEvents(Stream<? extends TrackedEventData<?>> eventEntryStream, Serializer serializer, EventUpcaster upcasterChain, boolean skipUnknownTypes) Upcasts and deserializes the given eventEntryStream using the given serializer and upcasterChain.

Methods inherited from class java.lang.Object

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

Method Detail

asTrackedEventMessage

public static <T> TrackedEventMessage<T> asTrackedEventMessage(EventMessage<T> eventMessage,
                                                               TrackingToken trackingToken)

Convert an EventMessage to a TrackedEventMessage using the given trackingToken. If the event is a DomainEventMessage the message will be converted to a GenericTrackedDomainEventMessage, otherwise a GenericTrackedEventMessage is returned.

Type Parameters:

T - the payload type of the event

Parameters:

eventMessage - the message to convert

trackingToken - the tracking token to use for the resulting message

Returns:

the message converted to a tracked event messge

asDomainEventMessage

public static <T> DomainEventMessage<T> asDomainEventMessage(EventMessage<T> eventMessage)

Convert a plain EventMessage to a DomainEventMessage. If the message already is a DomainEventMessage it will be returned as is. Otherwise a new GenericDomainEventMessage is made with null type, aggegrateIdentifier equal to messageIdentifier and sequence number of 0L.

Type Parameters:

T - The type of payload in the message

Parameters:

eventMessage - the input event message

Returns:

the message converted to a domain event message

upcastAndDeserializeDomainEvents

public static DomainEventStream upcastAndDeserializeDomainEvents(Stream<? extends DomainEventData<?>> eventEntryStream,
                                                                 Serializer serializer,
                                                                 EventUpcaster upcasterChain,
                                                                 boolean skipUnknownTypes)

Upcasts and deserializes the given eventEntryStream using the given serializer and upcasterChain.

The list of events returned contains lazy deserializing events for optimization purposes. Events represented with unknown classes are ignored if skipUnknownTypes is true

Parameters:

eventEntryStream - the stream of entries containing the data of the serialized event

serializer - the serializer to deserialize the event with

upcasterChain - the chain containing the upcasters to upcast the events with

skipUnknownTypes - whether unknown serialized types should be ignored

Returns:

a stream of lazy deserializing events

upcastAndDeserializeTrackedEvents

public static Stream<TrackedEventMessage<?>> upcastAndDeserializeTrackedEvents(Stream<? extends TrackedEventData<?>> eventEntryStream,
                                                                               Serializer serializer,
                                                                               EventUpcaster upcasterChain,
                                                                               boolean skipUnknownTypes)

Upcasts and deserializes the given eventEntryStream using the given serializer and upcasterChain.

The list of events returned contains lazy deserializing events for optimization purposes. Events represented with unknown classes are ignored if skipUnknownTypes is true

Parameters:

eventEntryStream - the stream of entries containing the data of the serialized event

serializer - the serializer to deserialize the event with

upcasterChain - the chain containing the upcasters to upcast the events with

skipUnknownTypes - whether unknown serialized types should be ignored

Returns:

a stream of lazy deserializing events

asStream

public static Stream<? extends DomainEventMessage<?>> asStream(DomainEventStream domainEventStream)

Convert the given domainEventStream to a regular java Stream of domain event messages.

Parameters:

domainEventStream - the input DomainEventStream

Returns:

the output Stream after conversion