Package org.frankframework.pipes

Class StringIteratorPipe

java.lang.Object

org.frankframework.core.TransactionAttributes

org.frankframework.pipes.AbstractPipe

org.frankframework.pipes.FixedForwardPipe

org.frankframework.pipes.MessageSendingPipe

org.frankframework.pipes.IteratingPipe<String>

org.frankframework.pipes.StringIteratorPipe

All Implemented Interfaces:

FrankElement, HasApplicationContext, HasName, HasSender, HasTransactionAttribute, IConfigurable, IForwardTarget, IPipe, IScopeProvider, IWithParameters, NameAware, EventThrowing, org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware, org.springframework.context.Lifecycle

Direct Known Subclasses:

ForEachChildElementPipe, JdbcIteratingPipeBase, StreamLineIteratorPipe

public abstract class StringIteratorPipe
extends IteratingPipe<String>

IteratingPipe that has Strings as items.

Author:

Gerrit van Brakel

Nested Class Summary

Nested classes/interfaces inherited from class org.frankframework.pipes.IteratingPipe

IteratingPipe.ItemCallback, IteratingPipe.StopReason

Nested classes/interfaces inherited from class org.frankframework.pipes.MessageSendingPipe

MessageSendingPipe.LinkMethod

Field Summary

Fields inherited from class org.frankframework.pipes.IteratingPipe

MAX_ITEMS_REACHED_FORWARD, msgTransformerPool, STOP_CONDITION_MET_FORWARD

Fields inherited from class org.frankframework.pipes.MessageSendingPipe

configurationMetrics, INPUT_VALIDATOR_NAME_PREFIX, INPUT_VALIDATOR_NAME_SUFFIX, INPUT_WRAPPER_NAME_PREFIX, INPUT_WRAPPER_NAME_SUFFIX, MAX_RETRY_INTERVAL, MESSAGE_LOG_NAME_PREFIX, MESSAGE_LOG_NAME_SUFFIX, MIN_RETRY_INTERVAL, msgLog, OUTPUT_VALIDATOR_NAME_PREFIX, OUTPUT_VALIDATOR_NAME_SUFFIX, OUTPUT_WRAPPER_NAME_PREFIX, OUTPUT_WRAPPER_NAME_SUFFIX, PIPE_CLEAR_TIMEOUT_MONITOR_EVENT, PIPE_EXCEPTION_MONITOR_EVENT, PIPE_TIMEOUT_MONITOR_EVENT

Fields inherited from class org.frankframework.pipes.AbstractPipe

parameterNamesMustBeUnique

Fields inherited from class org.frankframework.core.TransactionAttributes

log

Fields inherited from interface org.frankframework.core.IPipe

LONG_DURATION_MONITORING_EVENT, MESSAGE_SIZE_MONITORING_EVENT, PIPE_EXCEPTION_MONITORING_EVENT

Constructor Summary

Constructors

Constructor	Description
StringIteratorPipe()

Method Summary

Modifier and Type	Method	Description
void	configure()	Checks for correct configuration of forward.
protected IteratingPipe<String>.ItemCallback	createItemCallBack(PipeLineSession session, ISender sender, Writer writer)
protected String	getKey(String item)
void	setBlockPrefix(String string)	If combineBlocks = true, this string is inserted at the start of each block.
void	setBlockSize(int i)	Controls multiline behaviour.
void	setBlockSuffix(String string)	If combineBlocks = true, this string is inserted at the end of the set of lines.
void	setCombineBlocks(boolean combineBlocks)	If true, all items in a block are sent at once.
void	setEndPosition(int i)	If endPosition >= startPosition, this field contains the end position of the key in the current record
void	setEscapeXml(boolean escapeXml)	Escape XML characters in each item
void	setLinePrefix(String string)	This string is inserted at the start of each item
void	setLineSuffix(String string)	This string is appended at the end of each item
void	setStartPosition(int i)	If startPosition >= 0, this field contains the start position of the key in the current record (first character is 0); A sequence of lines with the same key is put in one block and send to the sender.

Methods inherited from class org.frankframework.pipes.IteratingPipe

getItem, getIterator, getStatisticsKeeper, getStopConditionTp, itemToMessage, iterateOverInput, sendMessage, setAddInputToResult, setCloseIteratorOnExit, setCollectResults, setIgnoreExceptions, setItemNoSessionKey, setMaxChildThreads, setMaxItems, setNamespaceDefs, setOmitXmlDeclaration, setOutputType, setParallel, setRemoveDuplicates, setRemoveXmlDeclarationInResults, setSender, setStopConditionXPathExpression, setStyleSheetName, setXpathExpression

Methods inherited from class org.frankframework.pipes.MessageSendingPipe

consumesSessionVariable, doLogToMessageLog, doPipe, increaseRetryIntervalAndWait, postSendAction, propagateName, sendMessageWithRetries, setCheckRootTag, setCheckXmlWellFormed, setExceptionOnResult, setHideMethod, setHideRegex, setInputValidator, setInputWrapper, setLinkMethod, setMaxRetries, setMessageLog, setName, setOutputValidator, setOutputWrapper, setPresumedTimeOutInterval, setResultOnTimeOut, setRetryMaxInterval, setRetryMinInterval, setRetryNamespaceDefs, setRetryXPath, setStubFilename, setTimeoutOnResult, setTimeOutOnResult, sizeStatisticsEnabled, start, stop, storeMessage

Methods inherited from class org.frankframework.pipes.FixedForwardPipe

getParameterValue, setIfParam, setIfValue, setOnlyIfSessionKey, setOnlyIfValue, setSkipOnEmptyInput, setUnlessSessionKey, setUnlessValue, skipPipe

Methods inherited from class org.frankframework.pipes.AbstractPipe

addForward, addParameter, createBean, findForward, getAdapter, getEventSourceName, getForwards, getParameterList, hasRegisteredForward, isRunning, registerEvent, setApplicationContext, setChompCharSize, setDurationThreshold, setElementToMove, setElementToMoveChain, setElementToMoveSessionKey, setEmptyInputReplacement, setGetInputFromFixedValue, setGetInputFromSessionKey, setLocker, setLogIntermediaryResults, setMaxThreads, setPreserveInput, setRemoveCompactMsgNamespaces, setRestoreMovedElements, setSecLogSessionKeys, setSizeStatistics, setStoreResultInSessionKey, setWriteToSecLog, throwEvent

Methods inherited from class org.frankframework.core.TransactionAttributes

configureTransactionAttributes, isTransacted, isTransacted, setTransacted, setTransactionTimeout

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.frankframework.core.FrankElement

addConfigWarning

Methods inherited from interface org.frankframework.core.HasApplicationContext

getApplicationContext, getConfigurationClassLoader

Methods inherited from interface org.frankframework.core.HasName

getName

Methods inherited from interface org.frankframework.core.HasSender

getSender

Methods inherited from interface org.frankframework.core.HasTransactionAttribute

getTransactionAttribute, getTransactionTimeout, getTxDef, setTransactionAttribute

Methods inherited from interface org.frankframework.core.IForwardTarget

getName

Methods inherited from interface org.frankframework.core.IPipe

getChompCharSize, getDurationThreshold, getElementToMove, getElementToMoveChain, getElementToMoveSessionKey, getEmptyInputReplacement, getGetInputFromFixedValue, getGetInputFromSessionKey, getHideRegex, getLocker, getLogIntermediaryResults, getMaxThreads, getSecLogSessionKeys, getStoreResultInSessionKey, isPreserveInput, isRemoveCompactMsgNamespaces, isRestoreMovedElements, isWriteToSecLog, setPipeLine, throwEvent

Constructor Details

StringIteratorPipe

public StringIteratorPipe()

Method Details

configure

public void configure()
               throws ConfigurationException

Description copied from class: FixedForwardPipe

Checks for correct configuration of forward.

Specified by:

configure in interface IConfigurable

Overrides:

configure in class IteratingPipe<String>

Throws:

ConfigurationException - in case it was not able to configure the component.

createItemCallBack

protected IteratingPipe<String>.ItemCallback createItemCallBack(PipeLineSession session,
 ISender sender,
 Writer writer)

Overrides:

createItemCallBack in class IteratingPipe<String>

getKey

protected String getKey(String item)

setBlockSize

public void setBlockSize(int i)

Controls multiline behaviour. If set to a value greater than 0, it specifies the number of rows send in a block to the sender.

Overrides:

setBlockSize in class IteratingPipe<String>

Default value

0 (one line at a time, no prefix of suffix)

setStartPosition

public void setStartPosition(int i)

If startPosition >= 0, this field contains the start position of the key in the current record (first character is 0); A sequence of lines with the same key is put in one block and send to the sender. Cannot be used in combination with blockSize.

Default value

-1

setEndPosition

public void setEndPosition(int i)

If endPosition >= startPosition, this field contains the end position of the key in the current record

Default value

-1

setCombineBlocks

public void setCombineBlocks(boolean combineBlocks)

If true, all items in a block are sent at once. If false, items are sent individually, potentially leveraging block enabled sending capabilities of the sender

Default value

true

setBlockPrefix

public void setBlockPrefix(String string)

If combineBlocks = true, this string is inserted at the start of each block. Requires blockSize or startPosition and endPosition to be set too.

Default value

<block>

setBlockSuffix

public void setBlockSuffix(String string)

If combineBlocks = true, this string is inserted at the end of the set of lines. Requires blockSize or startPosition and endPosition to be set too.

Default value

</block>

setLinePrefix

public void setLinePrefix(String string)

This string is inserted at the start of each item

setLineSuffix

public void setLineSuffix(String string)

This string is appended at the end of each item

setEscapeXml

public void setEscapeXml(boolean escapeXml)

Escape XML characters in each item

Default value

false