Package akka.actor.typed.internal
Class NoOpDeliveryFlightRecorder$
- java.lang.Object
-
- akka.actor.typed.internal.NoOpDeliveryFlightRecorder$
-
- All Implemented Interfaces:
DeliveryFlightRecorder
public class NoOpDeliveryFlightRecorder$ extends java.lang.Object implements DeliveryFlightRecorder
INTERNAL API
-
-
Field Summary
Fields Modifier and Type Field Description static NoOpDeliveryFlightRecorder$
MODULE$
Static reference to the singleton instance of this Scala object.
-
Constructor Summary
Constructors Constructor Description NoOpDeliveryFlightRecorder$()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
consumerChangedProducer(java.lang.String producerId)
void
consumerCreated(ActorPath path)
void
consumerDuplicate(java.lang.String producerId, long expectedSeqNr, long seqNr)
void
consumerMissing(java.lang.String producerId, long expectedSeqNr, long seqNr)
void
consumerReceived(java.lang.String producerId, long seqNr)
void
consumerReceivedPreviousInProgress(java.lang.String producerId, long seqNr, int stashed)
void
consumerReceivedResend(long seqNr)
void
consumerSentRequest(java.lang.String producerId, long requestedSeqNr)
void
consumerStarted(ActorPath path)
void
consumerStashFull(java.lang.String producerId, long seqNr)
void
producerCreated(java.lang.String producerId, ActorPath path)
void
producerReceived(java.lang.String producerId, long currentSeqNr)
void
producerReceivedRequest(java.lang.String producerId, long requestedSeqNr, long confirmedSeqNr)
void
producerReceivedResend(java.lang.String producerId, long fromSeqNr)
void
producerRequestNext(java.lang.String producerId, long currentSeqNr, long confirmedSeqNr)
void
producerResentFirst(java.lang.String producerId, long firstSeqNr)
void
producerResentFirstUnconfirmed(java.lang.String producerId, long seqNr)
void
producerResentUnconfirmed(java.lang.String producerId, long fromSeqNr, long toSeqNr)
void
producerSent(java.lang.String producerId, long seqNr)
void
producerStarted(java.lang.String producerId, ActorPath path)
void
producerWaitingForRequest(java.lang.String producerId, long currentSeqNr)
-
-
-
Field Detail
-
MODULE$
public static final NoOpDeliveryFlightRecorder$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Method Detail
-
producerCreated
public void producerCreated(java.lang.String producerId, ActorPath path)
- Specified by:
producerCreated
in interfaceDeliveryFlightRecorder
-
producerStarted
public void producerStarted(java.lang.String producerId, ActorPath path)
- Specified by:
producerStarted
in interfaceDeliveryFlightRecorder
-
producerRequestNext
public void producerRequestNext(java.lang.String producerId, long currentSeqNr, long confirmedSeqNr)
- Specified by:
producerRequestNext
in interfaceDeliveryFlightRecorder
-
producerSent
public void producerSent(java.lang.String producerId, long seqNr)
- Specified by:
producerSent
in interfaceDeliveryFlightRecorder
-
producerWaitingForRequest
public void producerWaitingForRequest(java.lang.String producerId, long currentSeqNr)
- Specified by:
producerWaitingForRequest
in interfaceDeliveryFlightRecorder
-
producerResentUnconfirmed
public void producerResentUnconfirmed(java.lang.String producerId, long fromSeqNr, long toSeqNr)
- Specified by:
producerResentUnconfirmed
in interfaceDeliveryFlightRecorder
-
producerResentFirst
public void producerResentFirst(java.lang.String producerId, long firstSeqNr)
- Specified by:
producerResentFirst
in interfaceDeliveryFlightRecorder
-
producerResentFirstUnconfirmed
public void producerResentFirstUnconfirmed(java.lang.String producerId, long seqNr)
- Specified by:
producerResentFirstUnconfirmed
in interfaceDeliveryFlightRecorder
-
producerReceived
public void producerReceived(java.lang.String producerId, long currentSeqNr)
- Specified by:
producerReceived
in interfaceDeliveryFlightRecorder
-
producerReceivedRequest
public void producerReceivedRequest(java.lang.String producerId, long requestedSeqNr, long confirmedSeqNr)
- Specified by:
producerReceivedRequest
in interfaceDeliveryFlightRecorder
-
producerReceivedResend
public void producerReceivedResend(java.lang.String producerId, long fromSeqNr)
- Specified by:
producerReceivedResend
in interfaceDeliveryFlightRecorder
-
consumerCreated
public void consumerCreated(ActorPath path)
- Specified by:
consumerCreated
in interfaceDeliveryFlightRecorder
-
consumerStarted
public void consumerStarted(ActorPath path)
- Specified by:
consumerStarted
in interfaceDeliveryFlightRecorder
-
consumerReceived
public void consumerReceived(java.lang.String producerId, long seqNr)
- Specified by:
consumerReceived
in interfaceDeliveryFlightRecorder
-
consumerReceivedPreviousInProgress
public void consumerReceivedPreviousInProgress(java.lang.String producerId, long seqNr, int stashed)
- Specified by:
consumerReceivedPreviousInProgress
in interfaceDeliveryFlightRecorder
-
consumerDuplicate
public void consumerDuplicate(java.lang.String producerId, long expectedSeqNr, long seqNr)
- Specified by:
consumerDuplicate
in interfaceDeliveryFlightRecorder
-
consumerMissing
public void consumerMissing(java.lang.String producerId, long expectedSeqNr, long seqNr)
- Specified by:
consumerMissing
in interfaceDeliveryFlightRecorder
-
consumerReceivedResend
public void consumerReceivedResend(long seqNr)
- Specified by:
consumerReceivedResend
in interfaceDeliveryFlightRecorder
-
consumerSentRequest
public void consumerSentRequest(java.lang.String producerId, long requestedSeqNr)
- Specified by:
consumerSentRequest
in interfaceDeliveryFlightRecorder
-
consumerChangedProducer
public void consumerChangedProducer(java.lang.String producerId)
- Specified by:
consumerChangedProducer
in interfaceDeliveryFlightRecorder
-
consumerStashFull
public void consumerStashFull(java.lang.String producerId, long seqNr)
- Specified by:
consumerStashFull
in interfaceDeliveryFlightRecorder
-
-