Uses of Class
org.frankframework.core.PipeLineSession

Packages that use PipeLineSession

Package	Description
org.frankframework.cache
org.frankframework.collection
org.frankframework.compression
org.frankframework.core
org.frankframework.http
org.frankframework.http.mime
org.frankframework.http.rest
org.frankframework.javascript
org.frankframework.jdbc
org.frankframework.ldap
org.frankframework.mongodb
org.frankframework.parameters
org.frankframework.pipes
org.frankframework.processors
org.frankframework.receivers
org.frankframework.senders
org.frankframework.soap
org.frankframework.stream
org.frankframework.threading
org.frankframework.util
org.frankframework.validation
org.frankframework.xml

Uses of PipeLineSession in org.frankframework.cache

Methods in org.frankframework.cache with parameters of type PipeLineSession

Modifier and Type	Method	Description
PipeRunResult	RemoveCacheKeyPipe.doPipe(Message message, PipeLineSession session)
String	AbstractCacheAdapter.transformKey(String input, PipeLineSession session)
K	ICache.transformKey(String input, PipeLineSession session)	Transform the the current request message to a key in the cache-map.
V	AbstractCacheAdapter.transformValue(Message value, PipeLineSession session)
V	ICache.transformValue(Message input, PipeLineSession session)	Transform the the current response message to a value in the cache-map.

Uses of PipeLineSession in org.frankframework.collection

Methods in org.frankframework.collection with parameters of type PipeLineSession

Modifier and Type	Method	Description
void	Collection.add(Message input, PipeLineSession session, ParameterValueList pvl)
protected void	AbstractCollectorPipe.addPartToCollection(Collection<C,P> collection, Message input, PipeLineSession session, ParameterValueList pvl)
protected Message	AbstractCollectorPipe.closeCollector(Collection<C,P> collection, PipeLineSession session)
protected abstract C	AbstractCollectorPipe.createCollector(Message input, PipeLineSession session)
P	ICollector.createPart(Message input, PipeLineSession session, ParameterValueList pvl)	Add a single item to the collection
protected final Message	AbstractCollectorPipe.doAction(AbstractCollectorPipe.Action action, Message input, PipeLineSession session)
PipeRunResult	AbstractCollectorPipe.doPipe(Message input, PipeLineSession session)
protected Collection<C,P>	AbstractCollectorPipe.getCollection(PipeLineSession session)
protected Collection<C,P>	AbstractCollectorSender.getCollection(PipeLineSession session)
protected ParameterValueList	AbstractCollectorPipe.getParameterValueList(Message input, PipeLineSession session)
SenderResult	AbstractCollectorSender.sendMessage(Message message, PipeLineSession session)

Uses of PipeLineSession in org.frankframework.compression

Methods in org.frankframework.compression with parameters of type PipeLineSession

Modifier and Type	Method	Description
protected ZipWriter	ZipWriterPipe.createCollector(Message input, PipeLineSession session)
MessageZipEntry	ZipWriter.createPart(Message input, PipeLineSession session, ParameterValueList pvl)
PipeRunResult	ZipWriterPipe.doPipe(Message input, PipeLineSession session)
protected IDataIterator<String>	ZipIteratorPipe.getIterator(Message input, PipeLineSession session, Map<String,Object> threadContext)
SenderResult	ZipWriterSender.sendMessage(Message message, PipeLineSession session)

Uses of PipeLineSession in org.frankframework.core

Methods in org.frankframework.core with parameters of type PipeLineSession

Modifier and Type	Method	Description
void	IListener.afterMessageProcessed(PipeLineResult processResult, RawMessageWrapper<M> rawMessage, PipeLineSession pipeLineSession)	Called to perform actions (like committing or sending a reply) after a message has been processed by the Pipeline.
void	IBlockEnabledSender.closeBlock(H blockHandle, PipeLineSession session)	close the resource that is opened by IBlockEnabledSender.openBlock(PipeLineSession).
PipeRunResult	AbstractResponseValidatorWrapper.doPipe(Message message, PipeLineSession session)
PipeRunResult	IPipe.doPipe(Message message, PipeLineSession session)	This is where the action takes place.
void	PipeLineSession.mergeToParentSession(String keysToCopy, PipeLineSession parentSession)	Copy specified keys from the from PipeLineSession to the parent PipeLineSession or Map to.
H	IBlockEnabledSender.openBlock(PipeLineSession session)	open a resource that can be used multiple times when IBlockEnabledSender.sendMessage(Object, Message, PipeLineSession) is called.
PipeLineResult	PipeLine.process(String messageId, Message message, PipeLineSession pipeLineSession)	The process method does the processing of a message. It retrieves the first pipe to execute from the firstPipe</code field, the call results in a PipRunResult, containing the next pipe to activate.

Uses of PipeLineSession in org.frankframework.http

Methods in org.frankframework.http with parameters of type PipeLineSession

Modifier and Type	Method	Description
void	PushingListenerAdapter.afterMessageProcessed(PipeLineResult processResult, RawMessageWrapper<Message> rawMessage, PipeLineSession pipeLineSession)
protected org.apache.http.client.methods.HttpRequestBase	HttpSender.createRequestMethod(URI uri, Message message, ParameterValueList parameters, PipeLineSession session)	Returns HttpRequestBase, with (optional) RAW or as BINARY content
Message	RestServiceDispatcher.dispatchRequest(String restPath, String uri, jakarta.servlet.http.HttpServletRequest httpServletRequest, String contentType, String request, PipeLineSession context, jakarta.servlet.http.HttpServletResponse httpServletResponse)	Dispatch a request.
protected org.apache.http.HttpResponse	AbstractHttpSession.execute(URI targetUri, org.apache.http.client.methods.HttpRequestBase httpRequestBase, PipeLineSession session)
protected abstract Message	AbstractHttpSender.extractResult(HttpResponseHandler responseHandler, PipeLineSession session)	Custom implementation to extract the response and format it to a String result.
protected Message	HttpSender.extractResult(HttpResponseHandler responseHandler, PipeLineSession session)
protected Message	WebServiceSender.extractResult(HttpResponseHandler responseHandler, PipeLineSession session)
protected abstract org.apache.http.client.methods.HttpRequestBase	AbstractHttpSender.getMethod(URI uri, Message message, ParameterValueList parameters, PipeLineSession session)	Custom implementation to create a HttpRequest object.
protected org.apache.http.client.methods.HttpRequestBase	HttpSender.getMethod(URI url, Message message, ParameterValueList parameters, PipeLineSession session)
protected org.apache.http.client.methods.HttpRequestBase	WebServiceSender.getMethod(URI uri, Message message, ParameterValueList parameters, PipeLineSession session)
Message	PushingListenerAdapter.processRequest(Message rawMessage, PipeLineSession session)
Message	RestListener.processRequest(Message message, PipeLineSession session)
Message	WebServiceListener.processRequest(Message message, PipeLineSession session)
static String	RestListenerUtils.retrieveRequestURL(PipeLineSession session)
SenderResult	AbstractHttpSender.sendMessage(Message message, PipeLineSession session)
static void	RestListenerUtils.setResponseContentType(PipeLineSession session, String contentType)	Deprecated.
RawMessageWrapper<Message>	PushingListenerAdapter.wrapRawMessage(Message rawMessage, PipeLineSession session)
static void	RestListenerUtils.writeToResponseOutputStream(PipeLineSession session, InputStream input)	Deprecated.

Uses of PipeLineSession in org.frankframework.http.mime

Methods in org.frankframework.http.mime with parameters of type PipeLineSession

Modifier and Type	Method	Description
org.apache.http.HttpEntity	HttpEntityFactory.create(Message message, ParameterValueList parameters, PipeLineSession session)
protected org.apache.http.entity.mime.FormBodyPart	HttpEntityFactory.elementToFormBodyPart(Element element, PipeLineSession session)

Uses of PipeLineSession in org.frankframework.http.rest

Methods in org.frankframework.http.rest with parameters of type PipeLineSession

Modifier and Type	Method	Description
PipeRunResult	ApiPrincipalPipe.doPipe(Message message, PipeLineSession session)

Uses of PipeLineSession in org.frankframework.javascript

Methods in org.frankframework.javascript with parameters of type PipeLineSession

Modifier and Type	Method	Description
void	GraalJS.registerCallback(ISender sender, PipeLineSession session)	Deprecated.
void	J2V8.registerCallback(ISender sender, PipeLineSession session)
void	JavascriptEngine.registerCallback(ISender sender, PipeLineSession session)	Allows for senders to be called by the Javascript function.

Uses of PipeLineSession in org.frankframework.jdbc

Methods in org.frankframework.jdbc with parameters of type PipeLineSession

Modifier and Type	Method	Description
void	JdbcListener.afterMessageProcessed(PipeLineResult processResult, RawMessageWrapper<M> rawMessage, PipeLineSession pipeLineSession)
void	SimpleJdbcListener.afterMessageProcessed(PipeLineResult processResult, RawMessageWrapper<String> rawMessage, PipeLineSession pipeLineSession)
void	DirectQuerySender.closeBlock(Connection connection, PipeLineSession session)
void	FixedQuerySender.closeBlock(QueryExecutionContext blockHandle, PipeLineSession session)
protected void	AbstractJdbcQuerySender.closeConnectionForSendMessage(Connection connection, PipeLineSession session)
protected void	DirectQuerySender.closeConnectionForSendMessage(Connection connection, PipeLineSession session)
protected Message	AbstractJdbcQuerySender.executeOtherQuery(Connection connection, PreparedStatement statement, String query, String resultQuery, PreparedStatement resStmt, Message message, PipeLineSession session, ParameterList parameterList)
protected Message	AbstractJdbcQuerySender.executeOtherQuery(QueryExecutionContext queryExecutionContext, Message message, PipeLineSession session)
protected Message	StoredProcedureQuerySender.executeOtherQuery(Connection connection, PreparedStatement statement, String query, String resultQuery, PreparedStatement resStmt, Message message, PipeLineSession session, ParameterList parameterList)
protected SenderResult	AbstractJdbcQuerySender.executeStatementSet(QueryExecutionContext queryExecutionContext, Message message, PipeLineSession session)
protected SenderResult	ResultSet2FileSender.executeStatementSet(QueryExecutionContext queryExecutionContext, Message message, PipeLineSession session)
protected IDataIterator<String>	JdbcIteratingPipeBase.getIterator(Message message, PipeLineSession session, Map<String,Object> threadContext)
Connection	DirectQuerySender.openBlock(PipeLineSession session)
QueryExecutionContext	FixedQuerySender.openBlock(PipeLineSession session)
final SenderResult	AbstractJdbcSender.sendMessage(Message message, PipeLineSession session)
SenderResult	DirectQuerySender.sendMessage(Connection connection, Message message, PipeLineSession session)
SenderResult	FixedQuerySender.sendMessage(QueryExecutionContext blockHandle, Message message, PipeLineSession session)
SenderResult	MessageStoreSender.sendMessage(Message message, PipeLineSession session)
SenderResult	XmlQuerySender.sendMessage(Connection blockHandle, Message message, PipeLineSession session)

Uses of PipeLineSession in org.frankframework.ldap

Methods in org.frankframework.ldap with parameters of type PipeLineSession

Modifier and Type	Method	Description
PipeRunResult	AbstractLdapQueryPipe.doPipe(Message message, PipeLineSession session)
abstract PipeRunResult	AbstractLdapQueryPipe.doPipeWithException(Message message, PipeLineSession session)
PipeRunResult	LdapFindGroupMembershipsPipe.doPipeWithException(Message message, PipeLineSession session)
PipeRunResult	LdapFindMemberPipe.doPipeWithException(Message message, PipeLineSession session)
String[]	LdapSender.getSubContextList(DirContext parentContext, String relativeContext, PipeLineSession session)	Return a list of all of the subcontexts of the current context, which is relative to parentContext.
String	LdapSender.performOperation(Message message, PipeLineSession session)	Performs the specified operation and returns the results.
SenderResult	LdapSender.sendMessage(Message message, PipeLineSession session)
void	LdapSender.storeLdapException(Throwable t, PipeLineSession session)

Uses of PipeLineSession in org.frankframework.mongodb

Methods in org.frankframework.mongodb with parameters of type PipeLineSession

Modifier and Type	Method	Description
SenderResult	MongoDbSender.sendMessage(Message message, PipeLineSession session)

Uses of PipeLineSession in org.frankframework.parameters

Methods in org.frankframework.parameters with parameters of type PipeLineSession

Modifier and Type	Method	Description
static ParameterValueList	ParameterValueList.get(ParameterList params, Message message, PipeLineSession session)
Object	AbstractParameter.getValue(ParameterValueList alreadyResolvedParameters, Message message, PipeLineSession session, boolean namespaceAware)	determines the raw value
Object	IParameter.getValue(ParameterValueList alreadyResolvedParameters, Message message, PipeLineSession session, boolean namespaceAware)
Object	NumberParameter.getValue(ParameterValueList alreadyResolvedParameters, Message message, PipeLineSession session, boolean namespaceAware)
ParameterValue	ParameterList.getValue(ParameterValueList alreadyResolvedParameters, IParameter p, Message message, PipeLineSession session, boolean namespaceAware)
ParameterValueList	ParameterList.getValues(Message message, PipeLineSession session)
ParameterValueList	ParameterList.getValues(Message message, PipeLineSession session, boolean namespaceAware)	Returns a List of ParameterValue objects

Uses of PipeLineSession in org.frankframework.pipes

Methods in org.frankframework.pipes with parameters of type PipeLineSession

Modifier and Type	Method	Description
protected String	StreamPipe.adjustFirstStringPart(String firstStringPart, PipeLineSession session)
protected PipeRunResult	Json2XmlValidator.alignJson(Message messageToValidate, PipeLineSession session, boolean responseMode)
protected PipeRunResult	Json2XmlValidator.alignXml2Json(Message messageToValidate, PipeLineSession session, boolean responseMode)
protected IteratingPipe<I>.ItemCallback	IteratingPipe.createItemCallBack(PipeLineSession session, ISender sender, Writer out)
protected IteratingPipe<String>.ItemCallback	StringIteratorPipe.createItemCallBack(PipeLineSession session, ISender sender, Writer writer)
protected final PipeForward	AbstractValidator.determineForward(AbstractXmlValidator.ValidationResult validationResult, PipeLineSession session, boolean responseMode, Supplier<String> errorMessageProvider)
protected PipeForward	XmlValidator.determineForward(AbstractXmlValidator.ValidationResult validationResult, PipeLineSession session, boolean responseMode)
protected String	AsyncSenderWithListenerPipe.doLogToMessageLog(Message input, PipeLineSession session, Message originalMessage, String messageID, String correlationID)
protected String	MessageSendingPipe.doLogToMessageLog(Message input, PipeLineSession session, Message originalMessage, String messageID, String correlationID)
final PipeRunResult	AbstractValidator.doPipe(Message message, PipeLineSession session)
PipeRunResult	AbstractValidator.doPipe(Message input, PipeLineSession session, boolean responseMode, String messageRoot)
PipeRunResult	Base64Pipe.doPipe(Message message, PipeLineSession session)
PipeRunResult	BytesOutputPipe.doPipe(Message message, PipeLineSession session)
PipeRunResult	ChecksumPipe.doPipe(Message message, PipeLineSession session)	Deprecated, for removal: This API element is subject to removal in a future version.
PipeRunResult	CompareIntegerPipe.doPipe(Message message, PipeLineSession session)
PipeRunResult	CompareStringPipe.doPipe(Message message, PipeLineSession session)
PipeRunResult	CompressPipe.doPipe(Message message, PipeLineSession session)
PipeRunResult	CounterSwitchPipe.doPipe(Message message, PipeLineSession session)
PipeRunResult	CredentialCheckingPipe.doPipe(Message message, PipeLineSession session)
PipeRunResult	CrlPipe.doPipe(Message message, PipeLineSession session)
PipeRunResult	CsvParserPipe.doPipe(Message message, PipeLineSession session)
PipeRunResult	DataSonnetPipe.doPipe(Message message, PipeLineSession session)
PipeRunResult	DelayPipe.doPipe(Message message, PipeLineSession session)
PipeRunResult	DomainTransformerPipe.doPipe(Message invoer, PipeLineSession session)
PipeRunResult	EchoPipe.doPipe(Message message, PipeLineSession session)
PipeRunResult	EscapePipe.doPipe(Message message, PipeLineSession session)
PipeRunResult	EtagHandlerPipe.doPipe(Message message, PipeLineSession session)	Deprecated.
PipeRunResult	ExceptionPipe.doPipe(Message message, PipeLineSession session)
PipeRunResult	FixedResultPipe.doPipe(Message message, PipeLineSession session)
PipeRunResult	ForPipe.doPipe(Message message, PipeLineSession session)
PipeRunResult	GetFromSession.doPipe(Message message, PipeLineSession session)
PipeRunResult	GetPrincipalPipe.doPipe(Message message, PipeLineSession session)
PipeRunResult	HashPipe.doPipe(Message message, PipeLineSession session)
PipeRunResult	IfPipe.doPipe(Message message, PipeLineSession session)
PipeRunResult	IncreaseIntegerPipe.doPipe(Message message, PipeLineSession session)
PipeRunResult	IsUserInRolePipe.doPipe(Message message, PipeLineSession session)
PipeRunResult	IsXmlPipe.doPipe(Message message, PipeLineSession session)
PipeRunResult	Json2XmlValidator.doPipe(Message input, PipeLineSession session, boolean responseMode, String messageRoot)	Validate the XML or JSON input, and align/convert it into JSON or XML according to a XML Schema.
PipeRunResult	JsonPipe.doPipe(Message message, PipeLineSession session)
PipeRunResult	JsonWellFormedChecker.doPipe(Message message, PipeLineSession session)
PipeRunResult	JwtPipe.doPipe(Message message, PipeLineSession session)
PipeRunResult	LogContextPipe.doPipe(Message message, PipeLineSession session)
PipeRunResult	MessageSendingPipe.doPipe(Message input, PipeLineSession session)
PipeRunResult	PasswordGeneratorPipe.doPipe(Message message, PipeLineSession session)
PipeRunResult	PasswordHashPipe.doPipe(Message message, PipeLineSession session)
PipeRunResult	PGPPipe.doPipe(Message message, PipeLineSession session)
PipeRunResult	PutInSession.doPipe(Message message, PipeLineSession session)
PipeRunResult	PutSystemDateInSession.doPipe(Message message, PipeLineSession session)
PipeRunResult	RegExPipe.doPipe(Message message, PipeLineSession session)
PipeRunResult	RemoveFromSession.doPipe(Message message, PipeLineSession session)
PipeRunResult	ReplacerPipe.doPipe(Message message, PipeLineSession session)
PipeRunResult	SignaturePipe.doPipe(Message message, PipeLineSession session)
PipeRunResult	SizePipe.doPipe(Message message, PipeLineSession session)
PipeRunResult	SkipPipe.doPipe(Message message, PipeLineSession session)
PipeRunResult	StreamPipe.doPipe(Message message, PipeLineSession session)
PipeRunResult	Text2XmlPipe.doPipe(Message message, PipeLineSession session)
PipeRunResult	TextSplitterPipe.doPipe(Message message, PipeLineSession session)
PipeRunResult	TimeoutGuardPipe.doPipe(Message message, PipeLineSession session)
PipeRunResult	UnzipPipe.doPipe(Message message, PipeLineSession session)
PipeRunResult	UUIDGeneratorPipe.doPipe(Message message, PipeLineSession session)
PipeRunResult	WsdlGeneratorPipe.doPipe(Message message, PipeLineSession session)
PipeRunResult	XmlIf.doPipe(Message message, PipeLineSession session)	Deprecated, for removal: This API element is subject to removal in a future version.
PipeRunResult	XmlSwitch.doPipe(Message message, PipeLineSession session)	This is where the action takes place, the switching is done.
PipeRunResult	XmlValidator.doPipe(Message input, PipeLineSession session, boolean responseMode, String messageRoot)
PipeRunResult	XmlWellFormedChecker.doPipe(Message message, PipeLineSession session)
PipeRunResult	XQueryPipe.doPipe(Message message, PipeLineSession session)
PipeRunResult	XsltPipe.doPipe(Message input, PipeLineSession session)
abstract PipeRunResult	TimeoutGuardPipe.doPipeWithTimeoutGuarded(Message input, PipeLineSession session)	doPipe wrapped around a TimeoutGuard
protected PipeRunResult	XmlValidator.getErrorResult(String reason, PipeLineSession session, boolean responseMode)
protected String	IsUserInRolePipe.getFirstMatchingUserRole(PipeLineSession session, List<String> roles)
protected InputStream	UnzipPipe.getInputStream(Message message, PipeLineSession session)
protected IDataIterator<I>	IteratingPipe.getIterator(Message input, PipeLineSession session, Map<String,Object> threadContext)
protected IDataIterator<String>	StreamLineIteratorPipe.getIterator(Message input, PipeLineSession session, Map<String,Object> threadContext)
DocumentFormat	Json2XmlValidator.getOutputFormat(PipeLineSession session, boolean responseMode)
protected Reader	StreamLineIteratorPipe.getReader(Message input, PipeLineSession session, Map<String,Object> threadContext)
List<Schema>	XmlValidator.getSchemas(PipeLineSession session)
String	XmlValidator.getSchemasId(PipeLineSession session)
int	MessageSendingPipe.increaseRetryIntervalAndWait(PipeLineSession session, int retryInterval, String description)
protected IteratingPipe.StopReason	ForEachChildElementPipe.iterateOverInput(Message input, PipeLineSession session, Map<String,Object> threadContext, IteratingPipe<String>.ItemCallback callback)
protected IteratingPipe.StopReason	IteratingPipe.iterateOverInput(Message input, PipeLineSession session, Map<String,Object> threadContext, IteratingPipe<I>.ItemCallback callback)
protected PipeRunResult	AsyncSenderWithListenerPipe.postSendAction(PipeRunResult sendResult, String correlationID, PipeLineSession session)
protected PipeRunResult	MessageSendingPipe.postSendAction(PipeRunResult sendResult, String correlationID, PipeLineSession session)
protected PipeRunResult	IteratingPipe.sendMessage(Message input, PipeLineSession session, ISender sender, Map<String,Object> threadContext)
protected PipeRunResult	MessageSendingPipe.sendMessage(Message input, PipeLineSession session, ISender sender, Map<String,Object> threadContext)
protected PipeRunResult	MessageSendingPipe.sendMessageWithRetries(Message input, Message originalMessage, PipeLineSession session)
boolean	FixedForwardPipe.skipPipe(Message input, PipeLineSession session)	Called by InputOutputPipeProcessor to check if the pipe needs to be skipped.
protected void	Json2XmlValidator.storeInputFormat(DocumentFormat format, Message input, PipeLineSession session, boolean responseMode)
protected final PipeForward	AbstractValidator.validate(String messageToValidate, PipeLineSession session)
protected abstract PipeForward	AbstractValidator.validate(Message messageToValidate, PipeLineSession session, boolean responseMode, String messageRoot)
PipeRunResult	AbstractValidator.validate(Message message, PipeLineSession session, String messageRoot)
protected PipeForward	JsonValidator.validate(Message messageToValidate, PipeLineSession session, boolean responseMode, String messageRoot)
protected PipeForward	WsdlXmlValidator.validate(Message messageToValidate, PipeLineSession session, boolean responseMode, String messageRoot)
protected PipeForward	XmlValidator.validate(Message messageToValidate, PipeLineSession session, boolean responseMode, String messageRoot)
PipeRunResult	XmlWellFormedChecker.validate(Message message, PipeLineSession session, String messageRoot)

Constructors in org.frankframework.pipes with parameters of type PipeLineSession

Modifier	Constructor	Description
	ItemCallback(PipeLineSession session, ISender sender, Writer out)

Uses of PipeLineSession in org.frankframework.processors

Methods in org.frankframework.processors with parameters of type PipeLineSession

Modifier and Type	Method	Description
protected String	CoreListenerProcessor.getLogPrefix(ICorrelatedPullingListener<M> listener, PipeLineSession session)
Message	CoreListenerProcessor.getMessage(ICorrelatedPullingListener<M> listener, String correlationID, PipeLineSession pipeLineSession)
Message	ListenerProcessor.getMessage(ICorrelatedPullingListener<M> listener, String correlationID, PipeLineSession pipeLineSession)
PipeRunResult	AbstractPipeProcessor.processPipe(PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession pipeLineSession)
protected abstract PipeRunResult	AbstractPipeProcessor.processPipe(PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession pipeLineSession, ThrowingFunction<Message,PipeRunResult,PipeRunException> chain)
protected PipeRunResult	CheckMessageSizePipeProcessor.processPipe(PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession pipeLineSession, ThrowingFunction<Message,PipeRunResult,PipeRunException> chain)
PipeRunResult	CorePipeProcessor.processPipe(PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession pipeLineSession)
protected PipeRunResult	ExceptionHandlingPipeProcessor.processPipe(PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession pipeLineSession, ThrowingFunction<Message,PipeRunResult,PipeRunException> chain)
PipeRunResult	InputOutputPipeProcessor.processPipe(PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession pipeLineSession)
protected PipeRunResult	InputOutputPipeProcessor.processPipe(PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession pipeLineSession, ThrowingFunction<Message,PipeRunResult,PipeRunException> chain)	Processes the pipe in the pipeline.
PipeRunResult	LimitingParallelExecutionPipeProcessor.processPipe(PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession pipeLineSession)
protected PipeRunResult	LimitingParallelExecutionPipeProcessor.processPipe(PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession pipeLineSession, ThrowingFunction<Message,PipeRunResult,PipeRunException> chain)
protected PipeRunResult	LockerPipeProcessor.processPipe(PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession pipeLineSession, ThrowingFunction<Message,PipeRunResult,PipeRunException> chain)
protected PipeRunResult	MonitoringPipeProcessor.processPipe(PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession pipeLineSession, ThrowingFunction<Message,PipeRunResult,PipeRunException> chain)
PipeRunResult	PipeProcessor.processPipe(PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession pipeLineSession)
protected PipeRunResult	TrackPreviousPipeInMetadataProcessor.processPipe(PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession pipeLineSession, ThrowingFunction<Message,PipeRunResult,PipeRunException> chain)
protected PipeRunResult	TransactionAttributePipeProcessor.processPipe(PipeLine pipeline, IPipe pipe, Message message, PipeLineSession pipeLineSession, ThrowingFunction<Message,PipeRunResult,PipeRunException> chain)
PipeLineResult	CachePipeLineProcessor.processPipeLine(PipeLine pipeLine, String messageId, Message message, PipeLineSession pipeLineSession, String firstPipe)
PipeLineResult	CorePipeLineProcessor.processPipeLine(PipeLine pipeLine, String messageId, Message message, PipeLineSession pipeLineSession, String firstPipe)
PipeLineResult	InputOutputPipeLineProcessor.processPipeLine(PipeLine pipeLine, String messageId, Message message, PipeLineSession pipeLineSession, String firstPipe)
PipeLineResult	LimitingParallelExecutionPipeLineProcessor.processPipeLine(PipeLine pipeLine, String messageId, Message message, PipeLineSession pipeLineSession, String firstPipe)
PipeLineResult	LockerPipeLineProcessor.processPipeLine(PipeLine pipeLine, String messageId, Message message, PipeLineSession pipeLineSession, String firstPipe)
PipeLineResult	PipeLineProcessor.processPipeLine(PipeLine pipeLine, String messageId, Message message, PipeLineSession pipeLineSession, String firstPipe)
PipeLineResult	TransactionAttributePipeLineProcessor.processPipeLine(PipeLine pipeLine, String messageId, Message message, PipeLineSession pipeLineSession, String firstPipe)
SenderResult	CacheSenderWrapperProcessor.sendMessage(AbstractSenderWrapper abstractSenderWrapper, Message message, PipeLineSession session)
SenderResult	CoreSenderWrapperProcessor.sendMessage(AbstractSenderWrapper abstractSenderWrapper, Message message, PipeLineSession session)
SenderResult	InputOutputSenderWrapperProcessor.sendMessage(AbstractSenderWrapper abstractSenderWrapper, Message message, PipeLineSession session)
SenderResult	SenderWrapperProcessor.sendMessage(AbstractSenderWrapper abstractSenderWrapper, Message message, PipeLineSession session)
PipeRunResult	AbstractPipeProcessor.validate(PipeLine pipeLine, IValidator validator, Message message, PipeLineSession pipeLineSession, String messageRoot)
PipeRunResult	CorePipeProcessor.validate(PipeLine pipeLine, IValidator validator, Message message, PipeLineSession pipeLineSession, String messageRoot)
PipeRunResult	LimitingParallelExecutionPipeProcessor.validate(PipeLine pipeLine, IValidator validator, Message message, PipeLineSession pipeLineSession, String messageRoot)
PipeRunResult	PipeProcessor.validate(PipeLine pipeLine, IValidator validator, Message message, PipeLineSession pipeLineSession, String messageRoot)

Uses of PipeLineSession in org.frankframework.receivers

Methods in org.frankframework.receivers with parameters of type PipeLineSession

Modifier and Type	Method	Description
void	FrankListener.afterMessageProcessed(PipeLineResult processResult, RawMessageWrapper<Message> rawMessage, PipeLineSession pipeLineSession)
void	JavaListener.afterMessageProcessed(PipeLineResult processResult, RawMessageWrapper<M> rawMessage, PipeLineSession pipeLineSession)
Message	ServiceDispatcher.dispatchRequest(String serviceName, Message message, PipeLineSession session)	Dispatch a request Message to a service by its configured name.
protected boolean	Receiver.isDeliveryRetryLimitExceededBeforeMessageProcessing(RawMessageWrapper<M> rawMessageWrapper, PipeLineSession session, boolean manualRetry)	returns true if message should not be processed when it is delivered.
void	Receiver.moveInProcessToError(RawMessageWrapper<M> rawMessageWrapper, PipeLineSession session, Instant receivedDate, String comments, org.springframework.transaction.TransactionDefinition txDef)	Move a message from the "in process" state or storage, to the error state or storage.
void	Receiver.processRawMessage(IListener<M> origin, RawMessageWrapper<M> rawMessage, PipeLineSession session, boolean retryStatusAlreadyChecked)	This method processes the raw message from the listener.
Message	FrankListener.processRequest(Message message, PipeLineSession session)
Message	JavaListener.processRequest(Message message, PipeLineSession session)
Message	Receiver.processRequest(IListener<M> origin, RawMessageWrapper<M> rawMessage, Message message, PipeLineSession session)	Process the received message with IMessageHandler.processRequest(IListener, RawMessageWrapper, Message, PipeLineSession).
Message	ServiceClient.processRequest(Message message, PipeLineSession session)	Method to implement for processing a request.
RawMessageWrapper<Message>	FrankListener.wrapRawMessage(Message rawMessage, PipeLineSession session)
RawMessageWrapper<M>	JavaListener.wrapRawMessage(M rawMessage, PipeLineSession session)

Uses of PipeLineSession in org.frankframework.senders

Methods in org.frankframework.senders that return PipeLineSession

Modifier and Type	Method	Description
PipeLineSession	ParallelSenderExecutor.getSession()

Methods in org.frankframework.senders with parameters of type PipeLineSession

Modifier and Type	Method	Description
void	IsolatedServiceCaller.callServiceAsynchronous(ServiceClient service, Message message, PipeLineSession session, ThreadLifeCycleEventListener<?> threadLifeCycleEventListener)
SenderResult	IsolatedServiceCaller.callServiceIsolated(ServiceClient service, Message message, PipeLineSession session, ThreadLifeCycleEventListener<?> threadLifeCycleEventListener)
protected ContentHandler	JsonXsltSender.createHandler(Message input, PipeLineSession session, TransformerPool poolToUse, ContentHandler handler, MessageBuilder messageBuilder)
protected ContentHandler	XsltSender.createHandler(Message input, PipeLineSession session, TransformerPool poolToUse, ContentHandler handler, MessageBuilder messageBuilder)
abstract SenderResult	AbstractSenderWrapper.doSendMessage(Message message, PipeLineSession session)
SenderResult	ParallelSenders.doSendMessage(Message message, PipeLineSession session)
SenderResult	ReconnectSenderWrapper.doSendMessage(Message message, PipeLineSession session)
SenderResult	SenderSeries.doSendMessage(Message input, PipeLineSession session)
SenderResult	SenderWrapper.doSendMessage(Message message, PipeLineSession session)
protected void	ShadowSender.executeGuarded(ISender sender, Message message, PipeLineSession session, Phaser guard, Map<ISender,ParallelSenderExecutor> executorMap)
AbstractMailSender.MailSessionBase	AbstractMailSender.extract(Message input, PipeLineSession session)	Reads fields from either paramList or Xml file
protected ContentHandler	XsltSender.filterInput(ContentHandler input, PipeLineSession session)
protected ParameterValueList	AbstractSenderWithParameters.getParameterValueList(Message input, PipeLineSession session)
protected TransformerPool	XsltSender.getTransformerPoolToUse(PipeLineSession session)
protected XMLReader	JsonXsltSender.getXmlReader(PipeLineSession session, ContentHandler handler)
protected XMLReader	XsltSender.getXmlReader(PipeLineSession session, ContentHandler handler)
final SenderResult	AbstractBlockEnabledSender.sendMessage(Message message, PipeLineSession session)
SenderResult	AbstractMailSender.sendMessage(Message message, PipeLineSession session)
SenderResult	AbstractSenderWrapper.sendMessage(Message message, PipeLineSession session)
SenderResult	CommandSender.sendMessage(Message message, PipeLineSession session)
SenderResult	DelaySender.sendMessage(Message message, PipeLineSession session)
SenderResult	EchoSender.sendMessage(Message message, PipeLineSession session)
SenderResult	FixedResultSender.sendMessage(Message message, PipeLineSession session)
SenderResult	FrankSender.sendMessage(Message message, PipeLineSession session)
SenderResult	IbisJavaSender.sendMessage(Message message, PipeLineSession session)
SenderResult	IbisLocalSender.sendMessage(Message message, PipeLineSession session)
SenderResult	JavascriptSender.sendMessage(Message message, PipeLineSession session)
SenderResult	LogSender.sendMessage(Message message, PipeLineSession session)
SenderResult	ReloadSender.sendMessage(Message message, PipeLineSession session)
SenderResult	ShadowSender.sendMessage(Message message, PipeLineSession session)	Override this from the parallel sender as it should only execute the original and shadowsenders here!
SenderResult	XmlValidatorSender.sendMessage(Message message, PipeLineSession session)
SenderResult	XsltSender.sendMessage(Message message, PipeLineSession session)	alternative implementation of send message, that should do the same as the original, but reuses the streaming content handler

Constructors in org.frankframework.senders with parameters of type PipeLineSession

Modifier	Constructor	Description
	IsolatedServiceExecutor(ServiceClient service, Message message, PipeLineSession session, CountDownLatch guard, ThreadLifeCycleEventListener<?> threadLifeCycleEventListener, boolean ownSession)
	ParallelSenderExecutor(ISender sender, Message message, PipeLineSession session, io.micrometer.core.instrument.DistributionSummary summary)

Uses of PipeLineSession in org.frankframework.soap

Methods in org.frankframework.soap with parameters of type PipeLineSession

Modifier and Type	Method	Description
void	SoapWrapper.checkForSoapFault(Message responseBody, Throwable nested, PipeLineSession session)
PipeRunResult	SoapWrapperPipe.doPipe(Message message, PipeLineSession session)
Message	SoapWrapper.getBody(Message message, boolean allowPlainXml, PipeLineSession session, String soapNamespaceSessionKey)
protected String	SoapWrapper.getFaultCode(Message message, PipeLineSession session)
protected String	SoapWrapper.getFaultString(Message message, PipeLineSession session)
String	SoapWrapper.getHeader(Message message, PipeLineSession session)
protected Message	SoapWrapperPipe.unwrapMessage(Message message, PipeLineSession session)
protected Message	SoapWrapperPipe.wrapMessage(Message message, String soapHeader, PipeLineSession session)

Uses of PipeLineSession in org.frankframework.stream

Methods in org.frankframework.stream with parameters of type PipeLineSession

Modifier and Type	Method	Description
void	Message.closeOnCloseOf(PipeLineSession session)
boolean	Message.isScheduledForCloseOnExitOf(PipeLineSession session)
void	Message.unscheduleFromCloseOnExitOf(PipeLineSession session)

Uses of PipeLineSession in org.frankframework.threading

Constructors in org.frankframework.threading with parameters of type PipeLineSession

Modifier	Constructor	Description
	ThreadConnector(Object owner, String description, ThreadLifeCycleEventListener<T> threadLifeCycleEventListener, IThreadConnectableTransactionManager<?,?> txManager, PipeLineSession session)

Uses of PipeLineSession in org.frankframework.util

Methods in org.frankframework.util with parameters of type PipeLineSession

Modifier and Type	Method	Description
static void	JdbcUtil.applyParameters(IDbmsSupport dbmsSupport, PreparedStatement statement, ParameterList parameters, Message message, PipeLineSession session)
static void	JdbcUtil.applyParameters(IDbmsSupport dbmsSupport, PreparedStatement statement, ParameterValueList parameters, PipeLineSession session)
static String	FileUtils.getFilename(ParameterList definedParameters, PipeLineSession session, File originalFile, String filenamePattern)
static org.apache.logging.log4j.CloseableThreadContext.Instance	LogUtil.getThreadContext(Adapter adapter, String messageId, PipeLineSession session)
void	RestoreMovedElementsHandler.setSession(PipeLineSession session)

Uses of PipeLineSession in org.frankframework.validation

Methods in org.frankframework.validation with parameters of type PipeLineSession

Modifier and Type	Method	Description
XMLReader	XercesXmlValidator.createValidatingParser(PipeLineSession session, AbstractValidationContext context)
AbstractValidationContext	AbstractXmlValidator.createValidationContext(PipeLineSession session, RootValidations rootValidations, Map<List<String>,List<String>> invalidRootNamespaces)
org.frankframework.validation.JavaxValidationContext	JavaxXmlValidator.createValidationContext(PipeLineSession session, RootValidations rootValidations, Map<List<String>,List<String>> invalidRootNamespaces)
org.frankframework.validation.XercesValidationContext	XercesXmlValidator.createValidationContext(PipeLineSession session, RootValidations rootValidations, Map<List<String>,List<String>> invalidRootNamespaces)
AbstractXmlValidator.ValidationResult	AbstractXmlValidator.finalizeValidation(AbstractValidationContext context, PipeLineSession session, Throwable t)	Evaluate the validation and set 'reason' session variables.
protected String	AbstractXmlValidator.getLogPrefix(PipeLineSession session)
protected org.frankframework.validation.PreparseResult	XercesXmlValidator.getPreparseResult(PipeLineSession session)
List<Schema>	SchemasProvider.getSchemas(PipeLineSession session)
String	SchemasProvider.getSchemasId(PipeLineSession session)
abstract ValidatorHandler	AbstractXmlValidator.getValidatorHandler(PipeLineSession session, AbstractValidationContext context)
ValidatorHandler	JavaxXmlValidator.getValidatorHandler(PipeLineSession session, AbstractValidationContext context)
ValidatorHandler	XercesXmlValidator.getValidatorHandler(PipeLineSession session, AbstractValidationContext context)
AbstractXmlValidator.ValidationResult	AbstractXmlValidator.validate(Message input, PipeLineSession session, ValidatorHandler validatorHandler, XMLFilterImpl filter, AbstractValidationContext context)
AbstractXmlValidator.ValidationResult	AbstractXmlValidator.validate(Message input, PipeLineSession session, RootValidations rootValidations, Map<List<String>,List<String>> invalidRootNamespaces)
AbstractXmlValidator.ValidationResult	AbstractXmlValidator.validate(InputSource inputSource, ValidatorHandler validatorHandler, PipeLineSession session, AbstractValidationContext context)

Uses of PipeLineSession in org.frankframework.xml

Methods in org.frankframework.xml with parameters of type PipeLineSession

Modifier and Type	Method	Description
ContentHandler	IXmlDebugger.inspectXml(PipeLineSession session, String label, ContentHandler contentHandler)	Allow the debugger to see the XML stream.

Constructors in org.frankframework.xml with parameters of type PipeLineSession

Modifier	Constructor	Description
	RootElementToSessionKeyFilter(PipeLineSession session, String rootElementSessionKey, String rootNamespaceSessionKey, ContentHandler handler)