Package akka.actor.typed.delivery

Class ConsumerController.Delivery<A>

java.lang.Object

akka.actor.typed.delivery.ConsumerController.Delivery<A>

Enclosing class:

ConsumerController

public static final class ConsumerController.Delivery<A>
extends java.lang.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, java.lang.String producerId, long seqNr)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

Delivery

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

Method Detail

message

public A message()

confirmTo

public ActorRef<ConsumerController.Confirmed> confirmTo()

producerId

public java.lang.String producerId()

seqNr

public long seqNr()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object