public class BatchFileTransformerPipe extends StreamTransformerPipe
originalBlockKey
parameterNamesMustBeUnique
log
LONG_DURATION_MONITORING_EVENT, MESSAGE_SIZE_MONITORING_EVENT, PIPE_EXCEPTION_MONITORING_EVENT
Constructor and Description |
---|
BatchFileTransformerPipe() |
Modifier and Type | Method and Description |
---|---|
PipeRunResult |
doPipe(Message input,
PipeLineSession session)
Open a reader for the file named according the input message and transform it.
|
protected InputStream |
getInputStream(String streamId,
Message input,
PipeLineSession session) |
protected String |
getStreamId(Message input,
PipeLineSession session) |
void |
setDelete(boolean b)
If set
true , the file processed will deleted after being processed, and not stored |
void |
setMove2dirAfterError(String errorDir)
Directory to which the inputfile is moved in case an error occurs
|
void |
setMove2dirAfterTransform(String readyDir)
Directory in which the transformed file(s) is stored
|
void |
setNumberOfBackups(int i)
Number of copies held of a file with the same name.
|
void |
setOverwrite(boolean b)
If set
true , the destination file will be deleted if it already exists |
closeAllBlocks, configure, getManager, getReader, getRecordHandler, getResultHandler, registerChild, registerChild, registerChild, registerChild, registerManager, registerRecordHandler, registerResultHandler, setCharset, setCloseInputstreamOnExit, setReaderFactory, setStoreOriginalBlock, start, stop
getParameterValue, setIfParam, setIfValue, setOnlyIfSessionKey, setOnlyIfValue, setSkipOnEmptyInput, setUnlessSessionKey, setUnlessValue, skipPipe
addParameter, consumesSessionVariable, createBean, findForward, getAdapter, getEventSourceName, getForwards, getInSizeStatDummyObject, getOutSizeStatDummyObject, getParameterList, hasSizeStatistics, registerEvent, registerForward, setApplicationContext, setChompCharSize, setDurationThreshold, setElementToMove, setElementToMoveChain, setElementToMoveSessionKey, setEmptyInputReplacement, setGetInputFromFixedValue, setGetInputFromSessionKey, setHideRegex, setLocker, setLogIntermediaryResults, setMaxThreads, setName, setPreserveInput, setRemoveCompactMsgNamespaces, setRestoreMovedElements, setSecLogSessionKeys, setSizeStatistics, setStoreResultInSessionKey, setWriteToSecLog, throwEvent
configureTransactionAttributes, isTransacted, isTransacted, setTransacted, setTransactionTimeout
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getChompCharSize, getDurationThreshold, getElementToMove, getElementToMoveChain, getElementToMoveSessionKey, getEmptyInputReplacement, getGetInputFromFixedValue, getGetInputFromSessionKey, getLocker, getSecLogSessionKeys, getStoreResultInSessionKey, isPreserveInput, isRemoveCompactMsgNamespaces, isRestoreMovedElements, isWriteToSecLog, setPipeLine, throwEvent
getMaxThreads
getName
getApplicationContext, getName
getConfigurationClassLoader
getName
getTransactionAttribute, getTransactionTimeout, getTxDef, setTransactionAttribute
protected String getStreamId(Message input, PipeLineSession session)
getStreamId
in class StreamTransformerPipe
protected InputStream getInputStream(String streamId, Message input, PipeLineSession session) throws PipeRunException
getInputStream
in class StreamTransformerPipe
PipeRunException
public PipeRunResult doPipe(Message input, PipeLineSession session) throws PipeRunException
doPipe
in interface IPipe
doPipe
in class StreamTransformerPipe
PipeRunException
IPipe.doPipe(Message, PipeLineSession)
public void setMove2dirAfterTransform(String readyDir)
public void setMove2dirAfterError(String errorDir)
public void setNumberOfBackups(int i)
public void setOverwrite(boolean b)
true
, the destination file will be deleted if it already existspublic void setDelete(boolean b)
true
, the file processed will deleted after being processed, and not storedCopyright © 2023 Frank!Framework. All rights reserved.