jp.go.nict.wisdom.daemonizer.command

Class DaemonizedStringIOCommand

java.lang.Object

jp.go.nict.wisdom.daemonizer.command.DaemonizedStringIOCommand

All Implemented Interfaces:

Command<String,String>

Direct Known Subclasses:

StandardInputCommand

public abstract class DaemonizedStringIOCommand
extends Object
implements Command<String,String>

This class manages a process of the target command, keeping it running.
The process starts when start() is invoked, and closes when close() is invoked.

Constructor Summary

Constructors

Constructor and Description
DaemonizedStringIOCommand(String[] cmd, String dir, Map<String,String> environment, int timeOut, int startWait, int restartwait, int bufSize)

Method Summary

Modifier and Type	Method and Description
void	clear()
void	close() Close the process.
protected String	doGetNextResult()
protected String	doGetNextResult(boolean includeDelim)
protected void	doPut(String input) Write input to stdin of the target.
protected abstract String	getDelimiter()
abstract String	getNextResult()
void	put(String input)
void	start() Invoke a process,and initialize thread pools.

Methods inherited from class java.lang.Object

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

Constructor Detail

DaemonizedStringIOCommand

public DaemonizedStringIOCommand(String[] cmd,
                                 String dir,
                                 Map<String,String> environment,
                                 int timeOut,
                                 int startWait,
                                 int restartwait,
                                 int bufSize)

Method Detail

doGetNextResult

protected String doGetNextResult()
                          throws InterruptedException,
                                 IOException

Throws:

InterruptedException

IOException

doPut

protected void doPut(String input)

Write input to stdin of the target.

Parameters:

input - Input string

start

public void start()
           throws IOException

Invoke a process,and initialize thread pools.

Specified by:

start in interface Command<String,String>

Throws:

IOException - Target command not found / Failed to start a process

close

public void close()
           throws IOException

Close the process.

Specified by:

close in interface Command<String,String>

Throws:

IOException - Failed to close

clear

public void clear()

Specified by:

clear in interface Command<String,String>

getNextResult

public abstract String getNextResult()
                              throws InterruptedException,
                                     IOException

Specified by:

getNextResult in interface Command<String,String>

Throws:

InterruptedException

IOException

put

public void put(String input)
         throws IOException

Specified by:

put in interface Command<String,String>

Throws:

IOException

getDelimiter

protected abstract String getDelimiter()

doGetNextResult

protected String doGetNextResult(boolean includeDelim)
                          throws InterruptedException,
                                 IOException

Throws:

InterruptedException

IOException