Package org.apache.pekko.persistence.query

Class EventEnvelope

java.lang.Object

org.apache.pekko.persistence.query.EventEnvelope

All Implemented Interfaces:

Serializable, scala.Equals, scala.Product, scala.Product4<Offset,String,Object,Object>

public final class EventEnvelope
extends Object
implements scala.Product4<Offset,String,Object,Object>, Serializable

Event wrapper adding meta data for the events in the result stream of pekko.persistence.query.scaladsl.EventsByTagQuery query, or similar queries.

The timestamp is the time the event was stored, in milliseconds since midnight, January 1, 1970 UTC (same as System.currentTimeMillis).

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
EventEnvelope(Offset offset, String persistenceId, long sequenceNr, Object event, long timestamp)
EventEnvelope(Offset offset, String persistenceId, long sequenceNr, Object event, long timestamp, scala.Option<Object> eventMetadata)

Method Summary

Modifier and Type	Method	Description
Offset	_1()
String	_2()
long	_3()
Object	_4()
static EventEnvelope	apply(Offset offset, String persistenceId, long sequenceNr, Object event, long timestamp)
static EventEnvelope	apply(Offset offset, String persistenceId, long sequenceNr, Object event, long timestamp, scala.Option<Object> meta)
boolean	canEqual(Object that)
EventEnvelope	copy(Offset offset, String persistenceId, long sequenceNr, Object event)
Offset	copy$default$1()
String	copy$default$2()
long	copy$default$3()
Object	copy$default$4()
boolean	equals(Object obj)
Object	event()
scala.Option<Object>	eventMetadata()
Optional<Object>	getEventMetaData()	Java API
int	hashCode()
Offset	offset()
String	persistenceId()
String	productPrefix()
long	sequenceNr()
long	timestamp()
String	toString()
static scala.Option<scala.Tuple4<Offset,String,Object,Object>>	unapply(EventEnvelope arg)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface scala.Product

productElementName, productElementNames, productIterator

Methods inherited from interface scala.Product4

productArity, productElement

Constructor Details

EventEnvelope

public EventEnvelope(Offset offset,
 String persistenceId,
 long sequenceNr,
 Object event,
 long timestamp,
 scala.Option<Object> eventMetadata)

EventEnvelope

public EventEnvelope(Offset offset,
 String persistenceId,
 long sequenceNr,
 Object event,
 long timestamp)

Method Details

apply

public static EventEnvelope apply(Offset offset,
 String persistenceId,
 long sequenceNr,
 Object event,
 long timestamp)

apply

public static EventEnvelope apply(Offset offset,
 String persistenceId,
 long sequenceNr,
 Object event,
 long timestamp,
 scala.Option<Object> meta)

unapply

public static scala.Option<scala.Tuple4<Offset,String,Object,Object>> unapply(EventEnvelope arg)

offset

public Offset offset()

persistenceId

public String persistenceId()

sequenceNr

public long sequenceNr()

event

public Object event()

timestamp

public long timestamp()

eventMetadata

public scala.Option<Object> eventMetadata()

getEventMetaData

public Optional<Object> getEventMetaData()

Java API

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Specified by:

equals in interface scala.Equals

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object

copy

public EventEnvelope copy(Offset offset,
 String persistenceId,
 long sequenceNr,
 Object event)

copy$default$1

public Offset copy$default$1()

copy$default$2

public String copy$default$2()

copy$default$3

public long copy$default$3()

copy$default$4

public Object copy$default$4()

productPrefix

public String productPrefix()

Specified by:

productPrefix in interface scala.Product

_1

public Offset _1()

Specified by:

_1 in interface scala.Product4<Offset,String,Object,Object>

_2

public String _2()

Specified by:

_2 in interface scala.Product4<Offset,String,Object,Object>

_3

public long _3()

Specified by:

_3 in interface scala.Product4<Offset,String,Object,Object>

_4

public Object _4()

Specified by:

_4 in interface scala.Product4<Offset,String,Object,Object>

canEqual

public boolean canEqual(Object that)

Specified by:

canEqual in interface scala.Equals