}
private final static Logger LOGGER = LoggerFactory.getLogger(ProcessWrapper.class);
+
public static final long READY_TIMEOUT_MS = 120000L;
private String processName, className;
private static class StreamGobbler extends Thread {
private final InputStream is;
- private final String pName;
+ private final Logger logger;
StreamGobbler(InputStream is, String name) {
super(name + "_ProcessStreamGobbler");
this.is = is;
- this.pName = name;
+ this.logger = LoggerFactory.getLogger(name);
}
@Override
try {
String line;
while ((line = br.readLine()) != null) {
- LOGGER.info(pName + " > " + line);
+ logger.info(line);
}
- } catch (IOException ignored) {
+ } catch (Exception ignored) {
// ignored
} finally {