Class TraceableMessagesHandler
- java.lang.Object
-
- org.apache.ignite.internal.processors.tracing.messages.TraceableMessagesHandler
-
public class TraceableMessagesHandler extends Object
Helper to handle traceable messages.
-
-
Constructor Summary
Constructors Constructor Description TraceableMessagesHandler(SpanManager spanMgr, IgniteLogger log)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidafterReceive(TraceableMessage msg)Called when message is received.voidbeforeSend(TraceableMessage msg)Called when message is going to be send.<T extends TraceableMessage>
Tbranch(T msg, TraceableMessage parent)Injects a sub-span tomsgas child span contained in givenparent.voidfinishProcessing(TraceableMessage msg)
-
-
-
Constructor Detail
-
TraceableMessagesHandler
public TraceableMessagesHandler(SpanManager spanMgr, IgniteLogger log)
- Parameters:
spanMgr- Span manager.log- Logger.
-
-
Method Detail
-
afterReceive
public void afterReceive(TraceableMessage msg)
Called when message is received. A span with name associated with given message will be created. from contained serialized spanSpanContainer.serializedSpanBytes()- Parameters:
msg- Traceable message.
-
beforeSend
public void beforeSend(TraceableMessage msg)
Called when message is going to be send. A serialized span will be created and attached toTraceableMessage.spanContainer().- Parameters:
msg- Traceable message.
-
branch
public <T extends TraceableMessage> T branch(T msg, TraceableMessage parent)
Injects a sub-span tomsgas child span contained in givenparent.- Type Parameters:
T- Traceable message type.- Parameters:
msg- Branched message.parent- Parent message.- Returns:
- Branched message with span context from parent message.
-
finishProcessing
public void finishProcessing(TraceableMessage msg)
- Parameters:
msg- Message.
-
-