Package akka.actor.typed.internal
Class WithMdcBehaviorInterceptor<T>
- java.lang.Object
-
- akka.actor.typed.BehaviorInterceptor<T,T>
-
- akka.actor.typed.internal.WithMdcBehaviorInterceptor<T>
-
public final class WithMdcBehaviorInterceptor<T> extends BehaviorInterceptor<T,T>
Support for Mapped Dagnostic Context for loggingINTERNAL 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 WithMdcBehaviorInterceptor()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static <T> Behavior<T>
apply(scala.collection.immutable.Map<java.lang.String,java.lang.Object> staticMdc, scala.Function1<T,scala.collection.immutable.Map<java.lang.String,java.lang.Object>> mdcForMessage, Behavior<T> behavior)
Behavior<T>
aroundReceive(TypedActorContext<T> ctx, T msg, BehaviorInterceptor.ReceiveTarget<T> target)
Intercept a message sent to the running actor.Behavior<T>
aroundSignal(TypedActorContext<T> ctx, Signal signal, BehaviorInterceptor.SignalTarget<T> target)
Intercept a signal sent to the running actor.Behavior<T>
aroundStart(TypedActorContext<T> ctx, BehaviorInterceptor.PreStartTarget<T> target)
Override to intercept actor startup.boolean
isSame(BehaviorInterceptor<java.lang.Object,java.lang.Object> other)
static scala.Function1<java.lang.Object,scala.collection.immutable.Map<java.lang.String,java.lang.Object>>
noMdcPerMessage()
java.lang.String
toString()
-
Methods inherited from class akka.actor.typed.BehaviorInterceptor
interceptMessageType
-
-
-
-
Method Detail
-
noMdcPerMessage
public static scala.Function1<java.lang.Object,scala.collection.immutable.Map<java.lang.String,java.lang.Object>> noMdcPerMessage()
-
apply
public static <T> Behavior<T> apply(scala.collection.immutable.Map<java.lang.String,java.lang.Object> staticMdc, scala.Function1<T,scala.collection.immutable.Map<java.lang.String,java.lang.Object>> mdcForMessage, Behavior<T> behavior)
-
aroundStart
public Behavior<T> aroundStart(TypedActorContext<T> ctx, BehaviorInterceptor.PreStartTarget<T> target)
Description copied from class:BehaviorInterceptor
Override to intercept actor startup. To trigger startup of the next behavior in the stack, calltarget.start()
.- Overrides:
aroundStart
in classBehaviorInterceptor<T,T>
- Parameters:
ctx
- (undocumented)target
- (undocumented)- Returns:
- The returned behavior will be the "started" behavior of the actor used to accept the next message or signal.
-
isSame
public boolean isSame(BehaviorInterceptor<java.lang.Object,java.lang.Object> other)
- Overrides:
isSame
in classBehaviorInterceptor<T,T>
- Parameters:
other
- (undocumented)- 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.
-
aroundReceive
public Behavior<T> aroundReceive(TypedActorContext<T> ctx, T msg, BehaviorInterceptor.ReceiveTarget<T> 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<T,T>
- Parameters:
ctx
- (undocumented)msg
- (undocumented)target
- (undocumented)- Returns:
- The behavior for next message or signal
-
aroundSignal
public Behavior<T> aroundSignal(TypedActorContext<T> ctx, Signal signal, BehaviorInterceptor.SignalTarget<T> target)
Description copied from class:BehaviorInterceptor
Intercept a signal sent to the running actor. Pass the signal on to the next behavior in the stack by passing it totarget.apply
.- Specified by:
aroundSignal
in classBehaviorInterceptor<T,T>
- Parameters:
ctx
- (undocumented)signal
- (undocumented)target
- (undocumented)- Returns:
- The behavior for next message or signal
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-