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

Class ConsumerController.Delivery<A>

java.lang.Object

org.apache.pekko.actor.typed.delivery.ConsumerController.Delivery<A>

Enclosing class:

ConsumerController

public static final class ConsumerController.Delivery<A>
extends Object

Received messages from the producer are wrapped in Delivery when sent to the consumer. When the message has been processed the consumer is supposed to send ConsumerController.Confirmed back to the ConsumerController via the confirmTo.

Constructor Summary

Constructors

Constructor	Description
Delivery(A message, ActorRef<ConsumerController.Confirmed> confirmTo, String producerId, long seqNr)

Method Summary

Modifier and Type	Method	Description
ActorRef<ConsumerController.Confirmed>	confirmTo()
A	message()
String	producerId()
long	seqNr()
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

Delivery

public Delivery(A message,
 ActorRef<ConsumerController.Confirmed> confirmTo,
 String producerId,
 long seqNr)

Method Details

message

public A message()

confirmTo

public ActorRef<ConsumerController.Confirmed> confirmTo()

producerId

public String producerId()

seqNr

public long seqNr()

toString

public String toString()

Overrides:

toString in class Object