org.thales.punch.apps.shiva.worker.impl

Class ApplicationStdIoCallback

java.lang.Object

org.thales.punch.apps.shiva.worker.impl.ApplicationStdIoCallback

All Implemented Interfaces:

org.thales.punch.libraries.forkexec.api.IStdOutErrCallback

public class ApplicationStdIoCallback
extends Object
implements org.thales.punch.libraries.forkexec.api.IStdOutErrCallback

This callback receives child process stdout or stderr outputs. It simply logs that to elasticsearch.

Note that some child applications are well designed and produce json logs, for these that json is leveraged and we generate a complete Json that also includes some extra information such as the runner id and shiva task name.

If the child application just produces stdout and stderr logs, we also generate a Json that encapsulate these logs in a single content.message field.

Last lines are truncated to avoid too big records flooding the log stream of the platform.

Author:

dimi

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ApplicationStdIoCallback.IO

Constructor Summary

Constructors

Constructor and Description
ApplicationStdIoCallback(ApplicationStdIoCallback.IO outputName, org.thales.punch.libraries.shiva.api.Application application) Create a callback to receive child process stdout and stderr logs

Method Summary

Modifier and Type	Method and Description
void	onReceive(String line)
static String	truncate(String line, int maxLength)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ApplicationStdIoCallback

public ApplicationStdIoCallback(ApplicationStdIoCallback.IO outputName,
                                org.thales.punch.libraries.shiva.api.Application application)

Create a callback to receive child process stdout and stderr logs

Parameters:

outputName - "out" or "err"

application - the target worker task, i.e. the child sub process

Method Detail

truncate

public static String truncate(String line,
                              int maxLength)

Parameters:

line - an input string

maxLength - the max length allowed

onReceive

public void onReceive(String line)

Specified by:

onReceive in interface org.thales.punch.libraries.forkexec.api.IStdOutErrCallback