Class EventEnvelope<Event>
- java.lang.Object
-
- org.apache.pekko.persistence.query.typed.EventEnvelope<Event>
-
public final class EventEnvelope<Event> extends java.lang.Object
Event wrapper adding meta data for the events in the result stream ofpekko.persistence.query.typed.scaladsl.EventsBySliceQuery
query, or similar queries.If the
event
is not defined it has not been loaded yet. It can be loaded withpekko.persistence.query.typed.scaladsl.LoadEventQuery
.The
timestamp
is the time the event was stored, in milliseconds since midnight, January 1, 1970 UTC (same asSystem.currentTimeMillis
).It is an improved
EventEnvelope
compared topekko.persistence.query.EventEnvelope
.API May Change
-
-
Constructor Summary
Constructors Constructor Description EventEnvelope(Offset offset, java.lang.String persistenceId, long sequenceNr, scala.Option<Event> eventOption, long timestamp, scala.Option<java.lang.Object> eventMetadata, java.lang.String entityType, int slice)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static <Event> EventEnvelope<Event>
apply(Offset offset, java.lang.String persistenceId, long sequenceNr, Event event, long timestamp, java.lang.String entityType, int slice)
static <Event> EventEnvelope<Event>
create(Offset offset, java.lang.String persistenceId, long sequenceNr, Event event, long timestamp, java.lang.String entityType, int slice)
java.lang.String
entityType()
boolean
equals(java.lang.Object obj)
Event
event()
scala.Option<java.lang.Object>
eventMetadata()
scala.Option<Event>
eventOption()
Event
getEvent()
Java APIjava.util.Optional<java.lang.Object>
getEventMetaData()
Java APIjava.util.Optional<Event>
getOptionalEvent()
Java APIint
hashCode()
Offset
offset()
java.lang.String
persistenceId()
long
sequenceNr()
int
slice()
long
timestamp()
java.lang.String
toString()
static <Event> scala.Option<scala.Tuple5<Offset,java.lang.String,java.lang.Object,scala.Option<Event>,java.lang.Object>>
unapply(EventEnvelope<Event> arg)
-
-
-
Method Detail
-
apply
public static <Event> EventEnvelope<Event> apply(Offset offset, java.lang.String persistenceId, long sequenceNr, Event event, long timestamp, java.lang.String entityType, int slice)
-
create
public static <Event> EventEnvelope<Event> create(Offset offset, java.lang.String persistenceId, long sequenceNr, Event event, long timestamp, java.lang.String entityType, int slice)
-
unapply
public static <Event> scala.Option<scala.Tuple5<Offset,java.lang.String,java.lang.Object,scala.Option<Event>,java.lang.Object>> unapply(EventEnvelope<Event> arg)
-
offset
public Offset offset()
-
persistenceId
public java.lang.String persistenceId()
-
sequenceNr
public long sequenceNr()
-
eventOption
public scala.Option<Event> eventOption()
-
timestamp
public long timestamp()
-
eventMetadata
public scala.Option<java.lang.Object> eventMetadata()
-
entityType
public java.lang.String entityType()
-
slice
public int slice()
-
event
public Event event()
-
getEvent
public Event getEvent()
Java API
-
getOptionalEvent
public java.util.Optional<Event> getOptionalEvent()
Java API
-
getEventMetaData
public java.util.Optional<java.lang.Object> getEventMetaData()
Java API
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
equals
public boolean equals(java.lang.Object obj)
- Overrides:
equals
in classjava.lang.Object
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-