Package org.apache.pekko.actor.typed.delivery

Class DurableProducerQueue.MessageSent<A>

java.lang.Object

org.apache.pekko.actor.typed.delivery.DurableProducerQueue.MessageSent<A>

All Implemented Interfaces:

DurableProducerQueue.Event, DeliverySerializable

Enclosing class:

DurableProducerQueue

public static final class DurableProducerQueue.MessageSent<A>
extends Object
implements DurableProducerQueue.Event

The fact (event) that a message has been sent.

Constructor Summary

Constructors

Constructor	Description
MessageSent(long seqNr, Object message, boolean ack, String confirmationQualifier, long timestampMillis)

Method Summary

Modifier and Type	Method	Description
boolean	ack()
String	confirmationQualifier()
boolean	equals(Object obj)
int	hashCode()
Object	message()
long	seqNr()
long	timestampMillis()
String	toString()
DurableProducerQueue.MessageSent<A>	withConfirmationQualifier(String qualifier)
DurableProducerQueue.MessageSent<A>	withTimestampMillis(long timestamp)

Methods inherited from class java.lang.Object

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

Constructor Details

MessageSent

public MessageSent(long seqNr,
 Object message,
 boolean ack,
 String confirmationQualifier,
 long timestampMillis)

Method Details

seqNr

public long seqNr()

message

public Object message()

ack

public boolean ack()

confirmationQualifier

public String confirmationQualifier()

timestampMillis

public long timestampMillis()

withConfirmationQualifier

public DurableProducerQueue.MessageSent<A> withConfirmationQualifier(String qualifier)

withTimestampMillis

public DurableProducerQueue.MessageSent<A> withTimestampMillis(long timestamp)

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object