Package akka.persistence.typed.telemetry

Class EventSourcedBehaviorEnsemble

java.lang.Object

akka.persistence.typed.telemetry.EventSourcedBehaviorEnsemble

All Implemented Interfaces:

EventSourcedBehaviorInstrumentation

public class EventSourcedBehaviorEnsemble
extends java.lang.Object
implements EventSourcedBehaviorInstrumentation

INTERNAL API

Constructor Summary

Constructors

Constructor	Description
EventSourcedBehaviorEnsemble(scala.collection.immutable.Seq<EventSourcedBehaviorInstrumentation> instrumentations)

Method Summary

Modifier and Type	Method	Description
void	actorInitialized(ActorRef<?> actorRef)	Initialize state for an EventSourcedBehavior actor.
void	afterRequestRecoveryPermit(ActorRef<?> actorRef, java.lang.Object context)	Record after a recovery permit is requested.
java.lang.Object	beforeRequestRecoveryPermit(ActorRef<?> actorRef)	Record before a recovery permit is requested.
scala.collection.immutable.Seq<java.lang.String>	dependencies()	Optional dependencies for this instrumentation.
scala.collection.immutable.Seq<EventSourcedBehaviorInstrumentation>	instrumentations()
java.lang.Object	persistEventCalled(ActorRef<?> actorRef, java.lang.Object event, java.lang.Object command)	Record persist event.
void	persistEventDone(ActorRef<?> actorRef, java.lang.Object context)	Record event is written and the registered callback is called.
java.lang.Object	persistEventWritten(ActorRef<?> actorRef, java.lang.Object event, java.lang.Object context)	Record event is written but the registered callback has not been called yet
void	persistFailed(ActorRef<?> actorRef, java.lang.Throwable throwable, java.lang.Object event, long seqNr, java.lang.Object context)	Record persistence persist failure.
void	persistRejected(ActorRef<?> actorRef, java.lang.Throwable throwable, java.lang.Object event, long seqNr, java.lang.Object context)	Record persistence persist failure.
void	recoveryDone(ActorRef<?> actorRef)	Record persistence recovery done.
void	recoveryFailed(ActorRef<?> actorRef, java.lang.Throwable throwable, java.lang.Object event)	Record persistence recovery failure.
void	recoveryStarted(ActorRef<?> actorRef)	Record persistence recovery started.

Methods inherited from class java.lang.Object

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

Constructor Detail

EventSourcedBehaviorEnsemble

public EventSourcedBehaviorEnsemble(scala.collection.immutable.Seq<EventSourcedBehaviorInstrumentation> instrumentations)

Method Detail

actorInitialized

public void actorInitialized(ActorRef<?> actorRef)

Description copied from interface: EventSourcedBehaviorInstrumentation

Initialize state for an EventSourcedBehavior actor.

Specified by:

actorInitialized in interface EventSourcedBehaviorInstrumentation

afterRequestRecoveryPermit

public void afterRequestRecoveryPermit(ActorRef<?> actorRef,
                                       java.lang.Object context)

Description copied from interface: EventSourcedBehaviorInstrumentation

Record after a recovery permit is requested.

Specified by:

afterRequestRecoveryPermit in interface EventSourcedBehaviorInstrumentation

Parameters:

actorRef - the ActorRef for which the recovery permit is requested

context - returned by beforeRequestRecoveryPermit

beforeRequestRecoveryPermit

public java.lang.Object beforeRequestRecoveryPermit(ActorRef<?> actorRef)

Description copied from interface: EventSourcedBehaviorInstrumentation

Record before a recovery permit is requested.

Specified by:

beforeRequestRecoveryPermit in interface EventSourcedBehaviorInstrumentation

Parameters:

actorRef - the ActorRef for which the recovery permit is about to be requested

Returns:

context that will be passed to afterRequestRecoveryPermit

dependencies

public scala.collection.immutable.Seq<java.lang.String> dependencies()

Description copied from interface: EventSourcedBehaviorInstrumentation

Optional dependencies for this instrumentation.

Dependency instrumentations will always be ordered before this instrumentation.

Specified by:

dependencies in interface EventSourcedBehaviorInstrumentation

Returns:

list of class names for optional instrumentation dependencies

instrumentations

public scala.collection.immutable.Seq<EventSourcedBehaviorInstrumentation> instrumentations()

persistEventCalled

public java.lang.Object persistEventCalled(ActorRef<?> actorRef,
                                           java.lang.Object event,
                                           java.lang.Object command)

Description copied from interface: EventSourcedBehaviorInstrumentation

Record persist event.

Specified by:

persistEventCalled in interface EventSourcedBehaviorInstrumentation

Parameters:

actorRef - the ActorRef for which the event will be sent to the journal.

event - the event that was submitted for persistence. For persist of several events it will be called for each event in the batch in the same order.

command - actor message (command), if any (otherwise null), for which the event was emitted.

Returns:

context that will be passed to persistEventWritten

persistEventDone

public void persistEventDone(ActorRef<?> actorRef,
                             java.lang.Object context)

Description copied from interface: EventSourcedBehaviorInstrumentation

Record event is written and the registered callback is called.

Specified by:

persistEventDone in interface EventSourcedBehaviorInstrumentation

Parameters:

actorRef - the ActorRef for which the event has been successfully persisted.

context - context returned by persistEventWritten

persistEventWritten

public java.lang.Object persistEventWritten(ActorRef<?> actorRef,
                                            java.lang.Object event,
                                            java.lang.Object context)

Description copied from interface: EventSourcedBehaviorInstrumentation

Record event is written but the registered callback has not been called yet

Specified by:

persistEventWritten in interface EventSourcedBehaviorInstrumentation

Parameters:

actorRef - the ActorRef for which the event has been successfully persisted.

event - the event that was stored in the journal.

context - context returned by persistEventCalled

Returns:

context that will be passed to persistEventDone

persistFailed

public void persistFailed(ActorRef<?> actorRef,
                          java.lang.Throwable throwable,
                          java.lang.Object event,
                          long seqNr,
                          java.lang.Object context)

Description copied from interface: EventSourcedBehaviorInstrumentation

Record persistence persist failure.

Specified by:

persistFailed in interface EventSourcedBehaviorInstrumentation

Parameters:

actorRef - the ActorRef for which the recovery has failed.

throwable - the cause of the failure.

event - the event that was to be persisted.

seqNr - the sequence number associated with the failure

context - context returned by persistEventCalled

persistRejected

public void persistRejected(ActorRef<?> actorRef,
                            java.lang.Throwable throwable,
                            java.lang.Object event,
                            long seqNr,
                            java.lang.Object context)

Description copied from interface: EventSourcedBehaviorInstrumentation

Record persistence persist failure.

Specified by:

persistRejected in interface EventSourcedBehaviorInstrumentation

Parameters:

actorRef - the ActorRef for which the recovery has failed.

throwable - the cause of the failure.

event - the event that was to be persisted.

seqNr - the sequence number associated with the failure

context - context returned by persistEventCalled

recoveryDone

public void recoveryDone(ActorRef<?> actorRef)

Description copied from interface: EventSourcedBehaviorInstrumentation

Record persistence recovery done.

Specified by:

recoveryDone in interface EventSourcedBehaviorInstrumentation

Parameters:

actorRef - the ActorRef for which the recovery is finished.

recoveryFailed

public void recoveryFailed(ActorRef<?> actorRef,
                           java.lang.Throwable throwable,
                           java.lang.Object event)

Description copied from interface: EventSourcedBehaviorInstrumentation

Record persistence recovery failure.

Specified by:

recoveryFailed in interface EventSourcedBehaviorInstrumentation

Parameters:

actorRef - the ActorRef for which the recovery has failed.

throwable - the cause of the failure.

event - the event that was replayed, if any (otherwise null)

recoveryStarted

public void recoveryStarted(ActorRef<?> actorRef)

Description copied from interface: EventSourcedBehaviorInstrumentation

Record persistence recovery started.

Specified by:

recoveryStarted in interface EventSourcedBehaviorInstrumentation

Parameters:

actorRef - the ActorRef for which the recovery is started.