public abstract class TimeoutGuardPipe extends FixedForwardPipe
parameterNamesMustBeUnique
log
LONG_DURATION_MONITORING_EVENT, MESSAGE_SIZE_MONITORING_EVENT, PIPE_EXCEPTION_MONITORING_EVENT
Constructor and Description |
---|
TimeoutGuardPipe() |
Modifier and Type | Method and Description |
---|---|
PipeRunResult |
doPipe(Message message,
PipeLineSession session)
This is where the action takes place.
|
abstract PipeRunResult |
doPipeWithTimeoutGuarded(Message input,
PipeLineSession session)
doPipe wrapped around a TimeoutGuard
|
int |
getTimeout() |
boolean |
isThrowException() |
protected void |
killPipe()
optional implementation to kill additional threads if the pipe may have created those.
|
void |
setThrowException(boolean b)
when
true , a piperunexception is thrown. |
void |
setTimeout(int i)
timeout in seconds of obtaining a result
|
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 abstract PipeRunResult doPipeWithTimeoutGuarded(Message input, PipeLineSession session) throws PipeRunException
PipeRunException
protected void killPipe()
public void setThrowException(boolean b)
true
, a piperunexception is thrown. otherwise the output is only logged as an error (and returned in a xml string with 'error' tags)public boolean isThrowException()
public int getTimeout()
public void setTimeout(int i)
Copyright © 2023 Frank!Framework. All rights reserved.