Package org.apache.pekko.actor.typed.internal

Class NoOpDeliveryFlightRecorder

java.lang.Object

org.apache.pekko.actor.typed.internal.NoOpDeliveryFlightRecorder

public class NoOpDeliveryFlightRecorder
extends Object

INTERNAL API

Constructor Summary

Constructors

Constructor	Description
NoOpDeliveryFlightRecorder()

Method Summary

Modifier and Type	Method	Description
static void	consumerChangedProducer(String producerId)
static void	consumerCreated(ActorPath path)
static void	consumerDuplicate(String producerId, long expectedSeqNr, long seqNr)
static void	consumerMissing(String producerId, long expectedSeqNr, long seqNr)
static void	consumerReceived(String producerId, long seqNr)
static void	consumerReceivedPreviousInProgress(String producerId, long seqNr, int stashed)
static void	consumerReceivedResend(long seqNr)
static void	consumerSentRequest(String producerId, long requestedSeqNr)
static void	consumerStarted(ActorPath path)
static void	consumerStashFull(String producerId, long seqNr)
static void	producerCreated(String producerId, ActorPath path)
static void	producerReceived(String producerId, long currentSeqNr)
static void	producerReceivedRequest(String producerId, long requestedSeqNr, long confirmedSeqNr)
static void	producerReceivedResend(String producerId, long fromSeqNr)
static void	producerRequestNext(String producerId, long currentSeqNr, long confirmedSeqNr)
static void	producerResentFirst(String producerId, long firstSeqNr)
static void	producerResentFirstUnconfirmed(String producerId, long seqNr)
static void	producerResentUnconfirmed(String producerId, long fromSeqNr, long toSeqNr)
static void	producerSent(String producerId, long seqNr)
static void	producerStarted(String producerId, ActorPath path)
static void	producerWaitingForRequest(String producerId, long currentSeqNr)

Methods inherited from class java.lang.Object

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

Constructor Details

NoOpDeliveryFlightRecorder

public NoOpDeliveryFlightRecorder()

Method Details

producerCreated

public static void producerCreated(String producerId,
 ActorPath path)

producerStarted

public static void producerStarted(String producerId,
 ActorPath path)

producerRequestNext

public static void producerRequestNext(String producerId,
 long currentSeqNr,
 long confirmedSeqNr)

producerSent

public static void producerSent(String producerId,
 long seqNr)

producerWaitingForRequest

public static void producerWaitingForRequest(String producerId,
 long currentSeqNr)

producerResentUnconfirmed

public static void producerResentUnconfirmed(String producerId,
 long fromSeqNr,
 long toSeqNr)

producerResentFirst

public static void producerResentFirst(String producerId,
 long firstSeqNr)

producerResentFirstUnconfirmed

public static void producerResentFirstUnconfirmed(String producerId,
 long seqNr)

producerReceived

public static void producerReceived(String producerId,
 long currentSeqNr)

producerReceivedRequest

public static void producerReceivedRequest(String producerId,
 long requestedSeqNr,
 long confirmedSeqNr)

producerReceivedResend

public static void producerReceivedResend(String producerId,
 long fromSeqNr)

consumerCreated

public static void consumerCreated(ActorPath path)

consumerStarted

public static void consumerStarted(ActorPath path)

consumerReceived

public static void consumerReceived(String producerId,
 long seqNr)

consumerReceivedPreviousInProgress

public static void consumerReceivedPreviousInProgress(String producerId,
 long seqNr,
 int stashed)

consumerDuplicate

public static void consumerDuplicate(String producerId,
 long expectedSeqNr,
 long seqNr)

consumerMissing

public static void consumerMissing(String producerId,
 long expectedSeqNr,
 long seqNr)

consumerReceivedResend

public static void consumerReceivedResend(long seqNr)

consumerSentRequest

public static void consumerSentRequest(String producerId,
 long requestedSeqNr)

consumerChangedProducer

public static void consumerChangedProducer(String producerId)

consumerStashFull

public static void consumerStashFull(String producerId,
 long seqNr)