public class DispatchedEvent<T extends Event> extends java.lang.Object implements EventEnvelope<T>
Constructor and Description |
---|
DispatchedEvent(java.lang.String entityId,
Int128 eventId,
T event,
java.lang.Integer swimlane,
java.lang.Long offset,
EventContext eventContext) |
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
|
Int128 |
getEventId()
The event id
|
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() |
public DispatchedEvent(java.lang.String entityId, Int128 eventId, T event, java.lang.Integer swimlane, java.lang.Long offset, EventContext eventContext)
public java.lang.String toString()
toString
in class java.lang.Object
public Int128 getEventId()
EventEnvelope
getEventId
in interface EventEnvelope<T extends Event>
public java.lang.Class<T> getEventType()
EventEnvelope
getEventType
in interface EventEnvelope<T extends Event>
public T getEvent()
EventEnvelope
getEvent
in interface EventEnvelope<T extends Event>
public java.lang.String getEntityId()
EventEnvelope
getEntityId
in interface EventEnvelope<T extends Event>
public java.lang.Integer getSwimlane()
EventEnvelope
getSwimlane
in interface EventEnvelope<T extends Event>
public java.lang.Long getOffset()
EventEnvelope
getOffset
in interface EventEnvelope<T extends Event>
public EventContext getEventContext()
EventEnvelope
getEventContext
in interface EventEnvelope<T extends Event>
UpdateOptions
,
FindOptions