org.axonframework.eventhandling

Class EventUtils

java.lang.Object

org.axonframework.eventhandling.EventUtils

public abstract class EventUtils
extends Object

Utility class for dealing with events.

Since:

3.0

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 <T> TrackedEventMessage<T>	asTrackedEventMessage(EventMessage<T> eventMessage, TrackingToken trackingToken) Convert an EventMessage to a TrackedEventMessage using the given trackingToken.
static Stream<TrackedEventMessage<?>>	upcastAndDeserializeTrackedEvents(Stream<? extends TrackedEventData<?>> eventEntryStream, Serializer serializer, EventUpcaster upcasterChain) 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

upcastAndDeserializeTrackedEvents

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

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

Returns:

a stream of lazy deserializing events