Package akka.persistence.typed.internal

Class PublishedEventImpl

java.lang.Object

akka.persistence.typed.internal.PublishedEventImpl

All Implemented Interfaces:

InternalProtocol, PublishedEvent, java.io.Serializable, scala.Equals, scala.Product

public final class PublishedEventImpl
extends java.lang.Object
implements PublishedEvent, InternalProtocol, scala.Product, java.io.Serializable

INTERNAL API

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface akka.persistence.typed.internal.InternalProtocol

InternalProtocol.IncomingCommand<C>, InternalProtocol.IncomingCommand$, InternalProtocol.JournalResponse, InternalProtocol.JournalResponse$, InternalProtocol.RecoveryPermitGranted$, InternalProtocol.RecoveryTickEvent, InternalProtocol.RecoveryTickEvent$, InternalProtocol.ReplicatedEventEnvelope<E>, InternalProtocol.ReplicatedEventEnvelope$, InternalProtocol.SnapshotterResponse, InternalProtocol.SnapshotterResponse$

Constructor Summary

Constructors

Constructor	Description
PublishedEventImpl(PersistenceId persistenceId, long sequenceNumber, java.lang.Object payload, long timestamp, scala.Option<ReplicatedPublishedEventMetaData> replicatedMetaData)

Method Summary

Modifier and Type	Method	Description
static PublishedEventImpl	apply(PersistenceId persistenceId, long sequenceNumber, java.lang.Object payload, long timestamp, scala.Option<ReplicatedPublishedEventMetaData> replicatedMetaData)
boolean	canEqual(java.lang.Object x$1)
PublishedEventImpl	copy(PersistenceId persistenceId, long sequenceNumber, java.lang.Object payload, long timestamp, scala.Option<ReplicatedPublishedEventMetaData> replicatedMetaData)
PersistenceId	copy$default$1()
long	copy$default$2()
java.lang.Object	copy$default$3()
long	copy$default$4()
scala.Option<ReplicatedPublishedEventMetaData>	copy$default$5()
boolean	equals(java.lang.Object x$1)
java.lang.Object	event()	User event
java.util.Optional<ReplicatedPublishedEventMetaData>	getReplicatedMetaData()	Java API: When emitted from an Replicated Event Sourcing actor this will contain the replica id
int	hashCode()
java.lang.Object	payload()
PersistenceId	persistenceId()
int	productArity()
java.lang.Object	productElement(int x$1)
java.lang.String	productElementName(int x$1)
scala.collection.Iterator<java.lang.Object>	productIterator()
java.lang.String	productPrefix()
scala.Option<ReplicatedPublishedEventMetaData>	replicatedMetaData()	Scala API: When emitted from an Replicated Event Sourcing actor this will contain the replica id
long	sequenceNumber()
scala.collection.immutable.Set<java.lang.String>	tags()
long	timestamp()
java.lang.String	toString()
static scala.Option<scala.Tuple5<PersistenceId,java.lang.Object,java.lang.Object,java.lang.Object,scala.Option<ReplicatedPublishedEventMetaData>>>	unapply(PublishedEventImpl x$0)
PublishedEvent	withoutTags()	If the published event is tagged, return a new published event with the payload unwrapped and the tags dropped, if it is not tagged return the published event as is.

Methods inherited from class java.lang.Object

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

Methods inherited from interface scala.Product

productElementNames

Constructor Detail

PublishedEventImpl

public PublishedEventImpl(PersistenceId persistenceId,
                          long sequenceNumber,
                          java.lang.Object payload,
                          long timestamp,
                          scala.Option<ReplicatedPublishedEventMetaData> replicatedMetaData)

Method Detail

apply

public static PublishedEventImpl apply(PersistenceId persistenceId,
                                       long sequenceNumber,
                                       java.lang.Object payload,
                                       long timestamp,
                                       scala.Option<ReplicatedPublishedEventMetaData> replicatedMetaData)

unapply

public static scala.Option<scala.Tuple5<PersistenceId,java.lang.Object,java.lang.Object,java.lang.Object,scala.Option<ReplicatedPublishedEventMetaData>>> unapply(PublishedEventImpl x$0)

persistenceId

public PersistenceId persistenceId()

Specified by:

persistenceId in interface PublishedEvent

sequenceNumber

public long sequenceNumber()

Specified by:

sequenceNumber in interface PublishedEvent

payload

public java.lang.Object payload()

timestamp

public long timestamp()

Specified by:

timestamp in interface PublishedEvent

replicatedMetaData

public scala.Option<ReplicatedPublishedEventMetaData> replicatedMetaData()

Description copied from interface: PublishedEvent

Scala API: When emitted from an Replicated Event Sourcing actor this will contain the replica id

Specified by:

replicatedMetaData in interface PublishedEvent

tags

public scala.collection.immutable.Set<java.lang.String> tags()

Specified by:

tags in interface PublishedEvent

event

public java.lang.Object event()

Description copied from interface: PublishedEvent

User event

Specified by:

event in interface PublishedEvent

withoutTags

public PublishedEvent withoutTags()

Description copied from interface: PublishedEvent

If the published event is tagged, return a new published event with the payload unwrapped and the tags dropped, if it is not tagged return the published event as is.

Specified by:

withoutTags in interface PublishedEvent

getReplicatedMetaData

public java.util.Optional<ReplicatedPublishedEventMetaData> getReplicatedMetaData()

Description copied from interface: PublishedEvent

Java API: When emitted from an Replicated Event Sourcing actor this will contain the replica id

Specified by:

getReplicatedMetaData in interface PublishedEvent

copy

public PublishedEventImpl copy(PersistenceId persistenceId,
                               long sequenceNumber,
                               java.lang.Object payload,
                               long timestamp,
                               scala.Option<ReplicatedPublishedEventMetaData> replicatedMetaData)

copy$default$1

public PersistenceId copy$default$1()

copy$default$2

public long copy$default$2()

copy$default$3

public java.lang.Object copy$default$3()

copy$default$4

public long copy$default$4()

copy$default$5

public scala.Option<ReplicatedPublishedEventMetaData> copy$default$5()

productPrefix

public java.lang.String productPrefix()

Specified by:

productPrefix in interface scala.Product

productArity

public int productArity()

Specified by:

productArity in interface scala.Product

productElement

public java.lang.Object productElement(int x$1)

Specified by:

productElement in interface scala.Product

productIterator

public scala.collection.Iterator<java.lang.Object> productIterator()

Specified by:

productIterator in interface scala.Product

canEqual

public boolean canEqual(java.lang.Object x$1)

Specified by:

canEqual in interface scala.Equals

productElementName

public java.lang.String productElementName(int x$1)

Specified by:

productElementName in interface scala.Product

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

equals

public boolean equals(java.lang.Object x$1)

Specified by:

equals in interface scala.Equals

Overrides:

equals in class java.lang.Object