Package org.codelibs.fess.helper

Class ProcessHelper

java.lang.Object

org.codelibs.fess.helper.ProcessHelper

public class ProcessHelper
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected int	processDestroyTimeout
protected final ConcurrentHashMap<String,JobProcess>	runningProcessMap

Constructor Summary

Constructors

Constructor	Description
ProcessHelper()

Method Summary

Modifier and Type	Method	Description
void	destroy()
int	destroyProcess(String sessionId)
protected int	destroyProcess(String sessionId, JobProcess jobProcess)
Set<String>	getRunningSessionIdSet()
boolean	isProcessRunning()
boolean	isProcessRunning(String sessionId)
void	sendCommand(String sessionId, String command)
void	setProcessDestroyTimeout(int processDestroyTimeout)
JobProcess	startProcess(String sessionId, List<String> cmdList, Consumer<ProcessBuilder> pbCall)
JobProcess	startProcess(String sessionId, List<String> cmdList, Consumer<ProcessBuilder> pbCall, int bufferSize, Consumer<String> outputCallback)

Methods inherited from class java.lang.Object

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

Field Details

runningProcessMap

protected final ConcurrentHashMap<String,JobProcess> runningProcessMap

processDestroyTimeout

protected int processDestroyTimeout

Constructor Details

ProcessHelper

public ProcessHelper()

Method Details

destroy

@PreDestroy
public void destroy()

startProcess

public JobProcess startProcess(String sessionId,
 List<String> cmdList,
 Consumer<ProcessBuilder> pbCall)

startProcess

public JobProcess startProcess(String sessionId,
 List<String> cmdList,
 Consumer<ProcessBuilder> pbCall,
 int bufferSize,
 Consumer<String> outputCallback)

destroyProcess

public int destroyProcess(String sessionId)

isProcessRunning

public boolean isProcessRunning()

isProcessRunning

public boolean isProcessRunning(String sessionId)

destroyProcess

protected int destroyProcess(String sessionId,
 JobProcess jobProcess)

getRunningSessionIdSet

public Set<String> getRunningSessionIdSet()

setProcessDestroyTimeout

public void setProcessDestroyTimeout(int processDestroyTimeout)

sendCommand

public void sendCommand(String sessionId,
 String command)