Package akka.actor.typed.internal
Class ActorFlightRecorder
- java.lang.Object
-
- akka.actor.typed.internal.ActorFlightRecorder
-
public class ActorFlightRecorder extends java.lang.Object
INTERNAL API
-
-
Constructor Summary
Constructors Constructor Description ActorFlightRecorder()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static void
consumerChangedProducer(java.lang.String producerId)
static void
consumerCreated(ActorPath path)
static void
consumerDuplicate(java.lang.String producerId, long expectedSeqNr, long seqNr)
static void
consumerMissing(java.lang.String producerId, long expectedSeqNr, long seqNr)
static void
consumerReceived(java.lang.String producerId, long seqNr)
static void
consumerReceivedPreviousInProgress(java.lang.String producerId, long seqNr, int stashed)
static void
consumerReceivedResend(long seqNr)
static void
consumerSentRequest(java.lang.String producerId, long requestedSeqNr)
static void
consumerStarted(ActorPath path)
static void
consumerStashFull(java.lang.String producerId, long seqNr)
static void
producerCreated(java.lang.String producerId, ActorPath path)
static void
producerReceived(java.lang.String producerId, long currentSeqNr)
static void
producerReceivedRequest(java.lang.String producerId, long requestedSeqNr, long confirmedSeqNr)
static void
producerReceivedResend(java.lang.String producerId, long fromSeqNr)
static void
producerRequestNext(java.lang.String producerId, long currentSeqNr, long confirmedSeqNr)
static void
producerResentFirst(java.lang.String producerId, long firstSeqNr)
static void
producerResentFirstUnconfirmed(java.lang.String producerId, long seqNr)
static void
producerResentUnconfirmed(java.lang.String producerId, long fromSeqNr, long toSeqNr)
static void
producerSent(java.lang.String producerId, long seqNr)
static void
producerStarted(java.lang.String producerId, ActorPath path)
static void
producerWaitingForRequest(java.lang.String producerId, long currentSeqNr)
-
-
-
Method Detail
-
producerCreated
public static void producerCreated(java.lang.String producerId, ActorPath path)
-
producerStarted
public static void producerStarted(java.lang.String producerId, ActorPath path)
-
producerRequestNext
public static void producerRequestNext(java.lang.String producerId, long currentSeqNr, long confirmedSeqNr)
-
producerSent
public static void producerSent(java.lang.String producerId, long seqNr)
-
producerWaitingForRequest
public static void producerWaitingForRequest(java.lang.String producerId, long currentSeqNr)
-
producerResentUnconfirmed
public static void producerResentUnconfirmed(java.lang.String producerId, long fromSeqNr, long toSeqNr)
-
producerResentFirst
public static void producerResentFirst(java.lang.String producerId, long firstSeqNr)
-
producerResentFirstUnconfirmed
public static void producerResentFirstUnconfirmed(java.lang.String producerId, long seqNr)
-
producerReceived
public static void producerReceived(java.lang.String producerId, long currentSeqNr)
-
producerReceivedRequest
public static void producerReceivedRequest(java.lang.String producerId, long requestedSeqNr, long confirmedSeqNr)
-
producerReceivedResend
public static void producerReceivedResend(java.lang.String producerId, long fromSeqNr)
-
consumerCreated
public static void consumerCreated(ActorPath path)
-
consumerStarted
public static void consumerStarted(ActorPath path)
-
consumerReceived
public static void consumerReceived(java.lang.String producerId, long seqNr)
-
consumerReceivedPreviousInProgress
public static void consumerReceivedPreviousInProgress(java.lang.String producerId, long seqNr, int stashed)
-
consumerDuplicate
public static void consumerDuplicate(java.lang.String producerId, long expectedSeqNr, long seqNr)
-
consumerMissing
public static void consumerMissing(java.lang.String producerId, long expectedSeqNr, long seqNr)
-
consumerReceivedResend
public static void consumerReceivedResend(long seqNr)
-
consumerSentRequest
public static void consumerSentRequest(java.lang.String producerId, long requestedSeqNr)
-
consumerChangedProducer
public static void consumerChangedProducer(java.lang.String producerId)
-
consumerStashFull
public static void consumerStashFull(java.lang.String producerId, long seqNr)
-
-