Class TraceableMessagesHandler


  • public class TraceableMessagesHandler
    extends Object
    Helper to handle traceable messages.
    • 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 span SpanContainer.serializedSpanBytes()
        Parameters:
        msg - Traceable message.
      • branch

        public <T extends TraceableMessage> T branch​(T msg,
                                                     TraceableMessage parent)
        Injects a sub-span to msg as child span contained in given parent.
        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.