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

Class NoOpDeliveryFlightRecorder$

java.lang.Object

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

All Implemented Interfaces:

DeliveryFlightRecorder

public class NoOpDeliveryFlightRecorder$
extends Object
implements DeliveryFlightRecorder

INTERNAL API

Field Summary

Fields

Modifier and Type	Field	Description
static final NoOpDeliveryFlightRecorder$	MODULE$	Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor	Description
NoOpDeliveryFlightRecorder$()

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Details

MODULE$

public static final NoOpDeliveryFlightRecorder$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

NoOpDeliveryFlightRecorder$

public NoOpDeliveryFlightRecorder$()

Method Details

producerCreated

public void producerCreated(String producerId,
 ActorPath path)

Specified by:

producerCreated in interface DeliveryFlightRecorder

producerStarted

public void producerStarted(String producerId,
 ActorPath path)

Specified by:

producerStarted in interface DeliveryFlightRecorder

producerRequestNext

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

Specified by:

producerRequestNext in interface DeliveryFlightRecorder

producerSent

public void producerSent(String producerId,
 long seqNr)

Specified by:

producerSent in interface DeliveryFlightRecorder

producerWaitingForRequest

public void producerWaitingForRequest(String producerId,
 long currentSeqNr)

Specified by:

producerWaitingForRequest in interface DeliveryFlightRecorder

producerResentUnconfirmed

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

Specified by:

producerResentUnconfirmed in interface DeliveryFlightRecorder

producerResentFirst

public void producerResentFirst(String producerId,
 long firstSeqNr)

Specified by:

producerResentFirst in interface DeliveryFlightRecorder

producerResentFirstUnconfirmed

public void producerResentFirstUnconfirmed(String producerId,
 long seqNr)

Specified by:

producerResentFirstUnconfirmed in interface DeliveryFlightRecorder

producerReceived

public void producerReceived(String producerId,
 long currentSeqNr)

Specified by:

producerReceived in interface DeliveryFlightRecorder

producerReceivedRequest

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

Specified by:

producerReceivedRequest in interface DeliveryFlightRecorder

producerReceivedResend

public void producerReceivedResend(String producerId,
 long fromSeqNr)

Specified by:

producerReceivedResend in interface DeliveryFlightRecorder

consumerCreated

public void consumerCreated(ActorPath path)

Specified by:

consumerCreated in interface DeliveryFlightRecorder

consumerStarted

public void consumerStarted(ActorPath path)

Specified by:

consumerStarted in interface DeliveryFlightRecorder

consumerReceived

public void consumerReceived(String producerId,
 long seqNr)

Specified by:

consumerReceived in interface DeliveryFlightRecorder

consumerReceivedPreviousInProgress

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

Specified by:

consumerReceivedPreviousInProgress in interface DeliveryFlightRecorder

consumerDuplicate

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

Specified by:

consumerDuplicate in interface DeliveryFlightRecorder

consumerMissing

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

Specified by:

consumerMissing in interface DeliveryFlightRecorder

consumerReceivedResend

public void consumerReceivedResend(long seqNr)

Specified by:

consumerReceivedResend in interface DeliveryFlightRecorder

consumerSentRequest

public void consumerSentRequest(String producerId,
 long requestedSeqNr)

Specified by:

consumerSentRequest in interface DeliveryFlightRecorder

consumerChangedProducer

public void consumerChangedProducer(String producerId)

Specified by:

consumerChangedProducer in interface DeliveryFlightRecorder

consumerStashFull

public void consumerStashFull(String producerId,
 long seqNr)

Specified by:

consumerStashFull in interface DeliveryFlightRecorder