io.eventuate

Class DispatchedEvent<T extends Event>

java.lang.Object

io.eventuate.DispatchedEvent<T>

All Implemented Interfaces:

EventEnvelope<T>

public class DispatchedEvent<T extends Event>
extends java.lang.Object
implements EventEnvelope<T>

Constructor Summary

Constructors

Constructor and Description
DispatchedEvent(java.lang.String entityId, io.eventuate.common.id.Int128 eventId, T event, java.lang.Integer swimlane, java.lang.Long offset, EventContext eventContext, java.util.Optional<java.util.Map<java.lang.String,java.lang.String>> eventMetadata)

Method Summary

Modifier and Type	Method and Description
java.lang.String	getEntityId() The id of the aggregate that published the event
T	getEvent() The event
EventContext	getEventContext() An opaque token that can used to update aggregates idempotently
io.eventuate.common.id.Int128	getEventId() The event id
java.util.Optional<java.util.Map<java.lang.String,java.lang.String>>	getEventMetadata()
java.lang.Class<T>	getEventType() The event type
java.lang.Long	getOffset() A monotonically increasing offset within the swimlane
java.lang.Integer	getSwimlane() Each aggregate (the sender) is assigned a swimlane, which can be used for concurrent event processing
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

DispatchedEvent

public DispatchedEvent(java.lang.String entityId,
                       io.eventuate.common.id.Int128 eventId,
                       T event,
                       java.lang.Integer swimlane,
                       java.lang.Long offset,
                       EventContext eventContext,
                       java.util.Optional<java.util.Map<java.lang.String,java.lang.String>> eventMetadata)

Method Detail

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

getEventId

public io.eventuate.common.id.Int128 getEventId()

Description copied from interface: EventEnvelope

The event id

Specified by:

getEventId in interface EventEnvelope<T extends Event>

Returns:

the event id

getEventType

public java.lang.Class<T> getEventType()

Description copied from interface: EventEnvelope

The event type

Specified by:

getEventType in interface EventEnvelope<T extends Event>

Returns:

the event type

getEvent

public T getEvent()

Description copied from interface: EventEnvelope

The event

Specified by:

getEvent in interface EventEnvelope<T extends Event>

Returns:

the event

getEntityId

public java.lang.String getEntityId()

Description copied from interface: EventEnvelope

The id of the aggregate that published the event

Specified by:

getEntityId in interface EventEnvelope<T extends Event>

Returns:

the entity id

getSwimlane

public java.lang.Integer getSwimlane()

Description copied from interface: EventEnvelope

Each aggregate (the sender) is assigned a swimlane, which can be used for concurrent event processing

Specified by:

getSwimlane in interface EventEnvelope<T extends Event>

Returns:

the swimlane

getOffset

public java.lang.Long getOffset()

Description copied from interface: EventEnvelope

A monotonically increasing offset within the swimlane

Specified by:

getOffset in interface EventEnvelope<T extends Event>

Returns:

the offset

getEventContext

public EventContext getEventContext()

Description copied from interface: EventEnvelope

An opaque token that can used to update aggregates idempotently

Specified by:

getEventContext in interface EventEnvelope<T extends Event>

Returns:

the context

See Also:

UpdateOptions, FindOptions

getEventMetadata

public java.util.Optional<java.util.Map<java.lang.String,java.lang.String>> getEventMetadata()

Specified by:

getEventMetadata in interface EventEnvelope<T extends Event>