public class CleanupOldFilesPipe extends FixedForwardPipe
parameterNamesMustBeUnique
log
LONG_DURATION_MONITORING_EVENT, MESSAGE_SIZE_MONITORING_EVENT, PIPE_EXCEPTION_MONITORING_EVENT
Constructor and Description |
---|
CleanupOldFilesPipe() |
Modifier and Type | Method and Description |
---|---|
PipeRunResult |
doPipe(Message message,
PipeLineSession session)
This is where the action takes place.
|
String |
getExcludeWildcard() |
String |
getFilePattern() |
String |
getFilePatternSessionKey() |
long |
getLastModifiedDelta() |
long |
getMinStableTime() |
String |
getWildcard() |
boolean |
isDeleteEmptySubdirectories() |
boolean |
isSubdirectories() |
void |
setDeleteEmptySubdirectories(boolean b)
when
true , empty subdirectories will be deleted, too |
void |
setExcludeWildcard(String excludeWildcard)
filter of files to be excluded for deletion
|
void |
setFilePattern(String string)
files that match this pattern will be deleted.
|
void |
setFilePatternSessionKey(String string)
session key that contains the pattern of files to be deleted, only used if filePattern is not set
|
void |
setLastModifiedDelta(long l)
time in milliseconds after last modification that must have passed at least before a file will be deleted (set to negative value to disable)
|
void |
setMinStableTime(long minStableTime)
Minimal age of file in milliseconds, to avoid deleting a file while it is still being written (only used when wildcard is set) (set to 0 to disable)
|
void |
setSubdirectories(boolean b)
when
true , files in subdirectories will be deleted, too |
void |
setWildcard(String string)
filter of files to delete.
|
configure, getParameterValue, setIfParam, setIfValue, setOnlyIfSessionKey, setOnlyIfValue, setSkipOnEmptyInput, setUnlessSessionKey, setUnlessValue, skipPipe
addParameter, consumesSessionVariable, createBean, findForward, getAdapter, getEventSourceName, getForwards, getInSizeStatDummyObject, getOutSizeStatDummyObject, getParameterList, getParameterOverriddenAttributeValue, getParameterValueList, hasSizeStatistics, registerEvent, registerForward, setApplicationContext, setChompCharSize, setDurationThreshold, setElementToMove, setElementToMoveChain, setElementToMoveSessionKey, setEmptyInputReplacement, setGetInputFromFixedValue, setGetInputFromSessionKey, setHideRegex, setLocker, setLogIntermediaryResults, setMaxThreads, setName, setPreserveInput, setRemoveCompactMsgNamespaces, setRestoreMovedElements, setSecLogSessionKeys, setSizeStatistics, setStoreResultInSessionKey, setWriteToSecLog, start, stop, 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
getMaxThreads
getName
getApplicationContext, getName
getConfigurationClassLoader
getName
getTransactionAttribute, getTransactionTimeout, getTxDef, setTransactionAttribute
public PipeRunResult doPipe(Message message, PipeLineSession session) throws PipeRunException
AbstractPipe
doPipe
in interface IPipe
doPipe
in class AbstractPipe
PipeRunException
public void setFilePattern(String string)
public String getFilePattern()
public void setFilePatternSessionKey(String string)
public String getFilePatternSessionKey()
public void setLastModifiedDelta(long l)
public long getLastModifiedDelta()
public void setSubdirectories(boolean b)
true
, files in subdirectories will be deleted, toopublic boolean isSubdirectories()
public void setDeleteEmptySubdirectories(boolean b)
true
, empty subdirectories will be deleted, toopublic boolean isDeleteEmptySubdirectories()
public void setWildcard(String string)
public String getWildcard()
public void setExcludeWildcard(String excludeWildcard)
public String getExcludeWildcard()
public void setMinStableTime(long minStableTime)
public long getMinStableTime()
Copyright © 2023 Frank!Framework. All rights reserved.