Class TraceListener

    • Constructor Detail

      • TraceListener

        public TraceListener()
        Default Constr.
      • TraceListener

        public TraceListener​(String name)
        Constructor that prefixes all log messages with the given name
        Parameters:
        name - name that will be used as prefix.
    • Method Detail

      • warningOccurred

        public void warningOccurred​(Job job,
                                    Node node,
                                    String messageId,
                                    String message,
                                    Throwable cause)
        Causes a Logger.warn(String, Throwable).
        Specified by:
        warningOccurred in interface JobListener
        Parameters:
        job - the affected job
        node - the node causing/issuing the warning or null if the failure wasn't related/caused by a particular node
        messageId - qualified message id
        message - the warning's details
        cause - a Throwable
      • stateChanged

        public void stateChanged​(Job job,
                                 Job.State oldState,
                                 Job.State newState)
        Causes a Logger.info(String).
        Specified by:
        stateChanged in interface JobListener
        Parameters:
        job - the affected job
        oldState - the previous state
        newState - the new state
      • executionFailed

        public void executionFailed​(Job job,
                                    Node node,
                                    String messageId,
                                    String reason,
                                    Throwable cause)
        Causes a Logger.fatal(String, Throwable).
        Specified by:
        executionFailed in interface JobListener
        Parameters:
        job - the affected job
        node - the node causing the failure or null if the failure wasn't related/caused by a particular node
        messageId - qualified message id
        reason - the reason of the failure
        cause - a Throwable
      • errorOccurred

        public void errorOccurred​(Job job,
                                  Node node,
                                  String messageId,
                                  String message,
                                  Throwable cause)
        Causes a Logger.error(String, Throwable).
        Specified by:
        errorOccurred in interface JobListener
        Parameters:
        job - the affected job
        node - the node causing/issuing the warning or null if the failure wasn't related/caused by a particular node
        messageId - qualified message id
        message - the warning's details
        cause - a Throwable
      • subPipelineCreated

        public void subPipelineCreated​(Job job,
                                       Node parent,
                                       Set<? extends Node> createdNodes)
        Causes a Logger.info(String)
        Specified by:
        subPipelineCreated in interface JobListener
        Parameters:
        job - the affected job
        parent - The node that triggered the creation. Might be null in cases where the parent node class is unknown on the client-side classpath
        createdNodes - The nodes that were created