public class ScriptParser extends AbstractBusComponent<String> implements BusDriver<String>, ArooaSessionAware
Constructor and Description |
---|
ScriptParser() |
Modifier and Type | Method and Description |
---|---|
protected void |
doProcessing() |
String |
getDelimiter()
Getter for delimiter.
|
SQLJob.DelimiterType |
getDelimiterType()
Getter for delimiterType.
|
String |
getEncoding()
Getter for encoding.
|
InputStream |
getInput() |
boolean |
isExpandProperties()
Getter for expandProperties.
|
boolean |
isKeepFormat()
Getter for keepFormat.
|
void |
run() |
void |
setArooaSession(ArooaSession session) |
void |
setDelimiter(String delimiter)
Setter for delimiter.
|
void |
setDelimiterType(SQLJob.DelimiterType delimiterType)
Setter for delimiterType.
|
void |
setEncoding(String encoding)
Setter for encoding.
|
void |
setExpandProperties(boolean expandProperties)
Setter for exapndProperties.
|
void |
setInput(InputStream input) |
void |
setKeepFormat(boolean keepformat)
Setter for keepFormat
|
void |
stop() |
protected void |
stopTheBus()
Implementation override this to perform the action of
stopping the bus.
|
accept, getServices, getTo, requestBusStop, setTo, startBus, stopBus
public void setArooaSession(ArooaSession session)
setArooaSession
in interface ArooaSessionAware
public boolean isKeepFormat()
public void setKeepFormat(boolean keepformat)
keepformat
- The keepFormat flag.public boolean isExpandProperties()
public void setExpandProperties(boolean expandProperties)
expandProperties
- The expandProperties flag.public SQLJob.DelimiterType getDelimiterType()
public void setDelimiterType(SQLJob.DelimiterType delimiterType)
delimiterType
- The delimiterType.public String getDelimiter()
public void setDelimiter(String delimiter)
delimiter
- The delimiter.public String getEncoding()
public void setEncoding(String encoding)
encoding
- The encoding.protected void doProcessing() throws BusException
BusException
protected void stopTheBus()
AbstractBusComponent
stopTheBus
in class AbstractBusComponent<String>
public void stop()
public InputStream getInput()
public void setInput(InputStream input)