Package akka.actor.typed.internal
Class LogMessagesInterceptor
- java.lang.Object
-
- akka.actor.typed.BehaviorInterceptor<java.lang.Object,java.lang.Object>
-
- akka.actor.typed.internal.LogMessagesInterceptor
-
public final class LogMessagesInterceptor extends BehaviorInterceptor<java.lang.Object,java.lang.Object>
Log all messages for this decorated ReceiveTarget[T] to logger before receiving it ourselves.INTERNAL API
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class akka.actor.typed.BehaviorInterceptor
BehaviorInterceptor.PreStartTarget<T>, BehaviorInterceptor.ReceiveTarget<T>, BehaviorInterceptor.SignalTarget<T>
-
-
Constructor Summary
Constructors Constructor Description LogMessagesInterceptor(LogOptions opts)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static <T> BehaviorInterceptor<T,T>
apply(LogOptions opts)
Behavior<java.lang.Object>
aroundReceive(TypedActorContext<java.lang.Object> ctx, java.lang.Object msg, BehaviorInterceptor.ReceiveTarget<java.lang.Object> target)
Intercept a message sent to the running actor.Behavior<java.lang.Object>
aroundSignal(TypedActorContext<java.lang.Object> ctx, Signal signal, BehaviorInterceptor.SignalTarget<java.lang.Object> target)
Override to intercept a signal sent to the running actor.boolean
isSame(BehaviorInterceptor<java.lang.Object,java.lang.Object> other)
LogOptions
opts()
-
Methods inherited from class akka.actor.typed.BehaviorInterceptor
aroundStart, interceptMessageClass
-
-
-
-
Constructor Detail
-
LogMessagesInterceptor
public LogMessagesInterceptor(LogOptions opts)
-
-
Method Detail
-
apply
public static <T> BehaviorInterceptor<T,T> apply(LogOptions opts)
-
opts
public LogOptions opts()
-
aroundReceive
public Behavior<java.lang.Object> aroundReceive(TypedActorContext<java.lang.Object> ctx, java.lang.Object msg, BehaviorInterceptor.ReceiveTarget<java.lang.Object> target)
Description copied from class:BehaviorInterceptor
Intercept a message sent to the running actor. Pass the message on to the next behavior in the stack by passing it totarget.apply
, returnBehaviors.same
without invokingtarget
to filter out the message.- Specified by:
aroundReceive
in classBehaviorInterceptor<java.lang.Object,java.lang.Object>
- Returns:
- The behavior for next message or signal
-
aroundSignal
public Behavior<java.lang.Object> aroundSignal(TypedActorContext<java.lang.Object> ctx, Signal signal, BehaviorInterceptor.SignalTarget<java.lang.Object> target)
Description copied from class:BehaviorInterceptor
Override to intercept a signal sent to the running actor. Pass the signal on to the next behavior in the stack by passing it totarget.apply
.- Overrides:
aroundSignal
in classBehaviorInterceptor<java.lang.Object,java.lang.Object>
- Returns:
- The behavior for next message or signal
- See Also:
BehaviorSignalInterceptor
-
isSame
public boolean isSame(BehaviorInterceptor<java.lang.Object,java.lang.Object> other)
- Overrides:
isSame
in classBehaviorInterceptor<java.lang.Object,java.lang.Object>
- Returns:
true
if this behavior logically the same as another behavior interceptor and can therefore be eliminated (to avoid building infinitely growing stacks of behaviors)? Default implementation is based on instance equality. Override to provide use case specific logic.
-
-