diff --git a/src/main/java/jp/sf/fess/helper/JobHelper.java b/src/main/java/jp/sf/fess/helper/JobHelper.java index 916933c5c..0769d76a5 100644 --- a/src/main/java/jp/sf/fess/helper/JobHelper.java +++ b/src/main/java/jp/sf/fess/helper/JobHelper.java @@ -25,8 +25,13 @@ import jp.sf.fess.job.JobExecutor; import org.apache.commons.io.IOUtils; import org.seasar.framework.container.annotation.tiger.DestroyMethod; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; public class JobHelper { + private static final Logger logger = LoggerFactory + .getLogger(JobHelper.class); + private final ConcurrentHashMap runningProcessMap = new ConcurrentHashMap(); private final ConcurrentHashMap runningJobExecutorMap = new ConcurrentHashMap(); @@ -66,18 +71,22 @@ public class JobHelper { try { IOUtils.closeQuietly(process.getInputStream()); } catch (final Exception e) { + logger.warn("Could not close a process input stream.", e); } try { IOUtils.closeQuietly(process.getErrorStream()); } catch (final Exception e) { + logger.warn("Could not close a process error stream.", e); } try { IOUtils.closeQuietly(process.getOutputStream()); } catch (final Exception e) { + logger.warn("Could not close a process output stream.", e); } try { process.destroy(); } catch (final Exception e) { + logger.error("Could not destroy a process correctly.", e); } } }