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.rest
org.frankframework.javascript
org.frankframework.jdbc
org.frankframework.jms
org.frankframework.ldap
org.frankframework.mongodb
org.frankframework.parameters
org.frankframework.pipes
org.frankframework.processors
org.frankframework.receivers
org.frankframework.scheduler
org.frankframework.senders
org.frankframework.soap
org.frankframework.stream
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	CacheAdapterBase.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	CacheAdapterBase.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	CollectorPipeBase.addPartToCollection(Collection<C,P> collection, Message input, PipeLineSession session, ParameterValueList pvl)
protected Message	CollectorPipeBase.closeCollector(Collection<C,P> collection, PipeLineSession session)
protected abstract C	CollectorPipeBase.createCollector(Message input, PipeLineSession session)
P	ICollector.createPart(Message input, PipeLineSession session, ParameterValueList pvl)	Add a single item to the collection
protected final Message	CollectorPipeBase.doAction(CollectorPipeBase.Action action, Message input, PipeLineSession session)
PipeRunResult	CollectorPipeBase.doPipe(Message input, PipeLineSession session)
protected Collection<C,P>	CollectorPipeBase.getCollection(PipeLineSession session)
protected Collection<C,P>	CollectorSenderBase.getCollection(PipeLineSession session)
protected ParameterValueList	CollectorPipeBase.getParameterValueList(Message input, PipeLineSession session)
SenderResult	CollectorSenderBase.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)
protected ZipInputStream	ZipIteratorPipe.getZipInputStream(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	IPipeLineExitHandler.atEndOfPipeLine(String correlationId, PipeLineResult pipeLineResult, PipeLineSession session)	Called to allow registered handler to perform cleanup or commit/rollback.
void	IBlockEnabledSender.closeBlock(H blockHandle, PipeLineSession session)	close the resource that is opened by IBlockEnabledSender.openBlock(PipeLineSession).
PipeRunResult	IPipe.doPipe(Message message, PipeLineSession session)	This is where the action takes place.
boolean	IRedeliveringListener.messageWillBeRedeliveredOnExitStateError(PipeLineSession pipeLineSession)
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)
Message	RestServiceDispatcher.dispatchRequest(String restPath, String uri, jakarta.servlet.http.HttpServletRequest httpServletRequest, String contentType, String request, PipeLineSession context, jakarta.servlet.http.HttpServletResponse httpServletResponse, jakarta.servlet.ServletContext servletContext)	Dispatch a request.
protected org.apache.http.entity.mime.FormBodyPart	HttpSender.elementToFormBodyPart(Element element, PipeLineSession session)
protected org.apache.http.entity.mime.FormBodyPart	MultipartHttpSender.elementToFormBodyPart(Element element, PipeLineSession session)	Deprecated.
protected org.apache.http.HttpResponse	HttpSessionBase.execute(URI targetUri, org.apache.http.client.methods.HttpRequestBase httpRequestBase, PipeLineSession session)
protected Message	HttpSender.extractResult(HttpResponseHandler responseHandler, PipeLineSession session)
protected abstract Message	HttpSenderBase.extractResult(HttpResponseHandler responseHandler, PipeLineSession session)	Custom implementation to extract the response and format it to a String result.
protected Message	RestSender.extractResult(HttpResponseHandler responseHandler, PipeLineSession session)	Deprecated.
protected Message	WebServiceSender.extractResult(HttpResponseHandler responseHandler, PipeLineSession session)
protected org.apache.http.client.methods.HttpRequestBase	HttpSender.getMethod(URI url, Message message, ParameterValueList parameters, PipeLineSession session)
protected abstract org.apache.http.client.methods.HttpRequestBase	HttpSenderBase.getMethod(URI uri, Message message, ParameterValueList parameters, PipeLineSession session)	Custom implementation to create a HttpRequest object.
protected org.apache.http.client.methods.HttpRequestBase	WebServiceSender.getMethod(URI uri, Message message, ParameterValueList parameters, PipeLineSession session)
static Message	HttpSender.handleMultipartResponse(String mimeType, InputStream inputStream, PipeLineSession session)	return the first part as Message and put the other parts as InputStream in the PipeLineSession
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	HttpSenderBase.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.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	J2V8.registerCallback(ISender sender, PipeLineSession session)
void	JavascriptEngine.registerCallback(ISender sender, PipeLineSession session)	Only used by J2V8, 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	DirectQuerySender.closeConnectionForSendMessage(Connection connection, PipeLineSession session)
protected void	JdbcQuerySenderBase.closeConnectionForSendMessage(Connection connection, PipeLineSession session)
protected Message	JdbcQuerySenderBase.executeOtherQuery(Connection connection, PreparedStatement statement, String query, String resultQuery, PreparedStatement resStmt, Message message, PipeLineSession session, ParameterList parameterList)
protected Message	JdbcQuerySenderBase.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 PipeRunResult	JdbcQuerySenderBase.executeSelectQuery(PreparedStatement statement, Object blobSessionVar, Object clobSessionVar, jakarta.servlet.http.HttpServletResponse response, String contentType, String contentDisposition, PipeLineSession session, IForwardTarget next)
protected PipeRunResult	JdbcQuerySenderBase.executeSelectQuery(PreparedStatement statement, Object blobSessionVar, Object clobSessionVar, PipeLineSession session, IForwardTarget next)
protected PipeRunResult	JdbcQuerySenderBase.executeStatementSet(QueryExecutionContext queryExecutionContext, Message message, PipeLineSession session, IForwardTarget next)
protected PipeRunResult	ResultSet2FileSender.executeStatementSet(QueryExecutionContext queryExecutionContext, Message message, PipeLineSession session, IForwardTarget next)
protected IDataIterator<String>	JdbcIteratingPipeBase.getIterator(Message message, PipeLineSession session, Map<String,Object> threadContext)
protected PipeRunResult	JdbcQuerySenderBase.getResult(ResultSet resultset, Object blobSessionVar, Object clobSessionVar, jakarta.servlet.http.HttpServletResponse response, String contentType, String contentDisposition, PipeLineSession session, IForwardTarget next)
Connection	DirectQuerySender.openBlock(PipeLineSession session)
QueryExecutionContext	FixedQuerySender.openBlock(PipeLineSession session)
SenderResult	DirectQuerySender.sendMessage(Connection blockHandle, Message message, PipeLineSession session)
SenderResult	FixedQuerySender.sendMessage(QueryExecutionContext blockHandle, Message message, PipeLineSession session)
final SenderResult	JdbcSenderBase.sendMessage(Message message, PipeLineSession session)
SenderResult	MessageStoreSender.sendMessage(Message message, PipeLineSession session)
protected PipeRunResult	DirectQuerySender.sendMessageOnConnection(Connection connection, Message message, PipeLineSession session, IForwardTarget next)
protected PipeRunResult	XmlQuerySender.sendMessageOnConnection(Connection connection, Message message, PipeLineSession session, IForwardTarget next)

Uses of PipeLineSession in org.frankframework.jms

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

Modifier and Type	Method	Description
void	JmsListenerBase.afterMessageProcessed(PipeLineResult plr, RawMessageWrapper<jakarta.jms.Message> rawMessageWrapper, PipeLineSession session)
void	PullingJmsListener.afterMessageProcessed(PipeLineResult plr, RawMessageWrapper<jakarta.jms.Message> rawMessageWrapper, PipeLineSession pipeLineSession)
jakarta.jms.Destination	JmsSender.getDestination(PipeLineSession session, ParameterValueList pvl)
protected Map<String,Object>	JmsListenerBase.getMessageProperties(PipeLineSession session)	Set additional message headers/properties on the JMS response, read after message has been processed!
boolean	JmsListenerBase.messageWillBeRedeliveredOnExitStateError(PipeLineSession pipeLineSession)
SenderResult	JmsSender.sendMessage(Message message, PipeLineSession session)
Message	JmsSender.sendMessage(Message message, PipeLineSession pipeLineSession, String soapHeader)
SenderResult	XmlJmsBrowserSender.sendMessage(Message message, PipeLineSession session)
protected void	JmsListenerBase.sendReply(PipeLineResult plr, jakarta.jms.Destination replyTo, String replyCid, long timeToLive, boolean ignoreInvalidDestinationException, PipeLineSession pipeLineSession, Map<String,Object> properties)
protected void	PullingJmsListener.sendReply(PipeLineResult plr, jakarta.jms.Destination replyTo, String replyCid, long timeToLive, boolean ignoreInvalidDestinationException, PipeLineSession pipeLineSession, Map<String,Object> properties)
RawMessageWrapper<jakarta.jms.Message>	PushingJmsListener.wrapRawMessage(jakarta.jms.Message rawMessage, 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	LdapChallengePipe.doPipe(Message msg, PipeLineSession pls)	Deprecated. Checks to see if the supplied parameteres of the pipe can login to LDAP
PipeRunResult	LdapQueryPipeBase.doPipe(Message message, PipeLineSession session)
PipeRunResult	LdapFindGroupMembershipsPipe.doPipeWithException(Message message, PipeLineSession session)
PipeRunResult	LdapFindMemberPipe.doPipeWithException(Message message, PipeLineSession session)
abstract PipeRunResult	LdapQueryPipeBase.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.
protected void	LdapChallengePipe.handleError(LdapSender ldapSender, PipeLineSession session, int code, String message)	Deprecated.
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
void	ParameterList.addMatchingSessionKeys(ParameterValueList result, Parameter parm, Message message, PipeLineSession session, boolean namespaceAware)
static ParameterValueList	ParameterValueList.get(ParameterList params, Message message, PipeLineSession session)
Object	Parameter.getValue(ParameterValueList alreadyResolvedParameters, Message message, PipeLineSession session, boolean namespaceAware)	determines the raw value
ParameterValue	ParameterList.getValue(ParameterValueList alreadyResolvedParameters, Parameter 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(String messageToValidate, PipeLineSession session, boolean responseMode)
protected PipeRunResult	Json2XmlValidator.alignXml2Json(String messageToValidate, PipeLineSession session, boolean responseMode)
protected void	ForEachChildElementPipe.createHandler(org.frankframework.pipes.ForEachChildElementPipe.HandlerRecord result, ThreadConnector<?> threadConnector, Message input, PipeLineSession session, IteratingPipe<String>.ItemCallback callback)
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	ValidatorBase.determineForward(AbstractXmlValidator.ValidationResult validationResult, PipeLineSession session, boolean responseMode, Supplier<String> errorMessageProvider)
protected PipeForward	XmlValidator.determineForward(AbstractXmlValidator.ValidationResult validationResult, PipeLineSession session, boolean responseMode)
PipeRunResult	Base64Pipe.doPipe(Message message, PipeLineSession session)
PipeRunResult	BytesOutputPipe.doPipe(Message message, PipeLineSession session)
PipeRunResult	ChecksumPipe.doPipe(Message message, PipeLineSession session)
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	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	FileLineIteratorPipe.doPipe(Message input, PipeLineSession session)	Deprecated. Open a reader for the file named according the input messsage and transform it.
PipeRunResult	FilenameSwitch.doPipe(Message message, PipeLineSession session)	Deprecated.
PipeRunResult	FixedResultPipe.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	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	PostboxRetrieverPipe.doPipe(Message message, PipeLineSession session)	Deprecated.
PipeRunResult	PutInSession.doPipe(Message message, PipeLineSession session)
PipeRunResult	PutParametersInSession.doPipe(Message message, PipeLineSession session)	Deprecated.
PipeRunResult	PutSystemDateInSession.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	Stream2StringPipe.doPipe(Message message, PipeLineSession session)	Deprecated.
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)
final PipeRunResult	ValidatorBase.doPipe(Message message, PipeLineSession session)
PipeRunResult	ValidatorBase.doPipe(Message input, PipeLineSession session, boolean responseMode, String messageRoot)
PipeRunResult	ValidatorBase.ResponseValidatorWrapper.doPipe(Message message, PipeLineSession session)
PipeRunResult	WsdlGeneratorPipe.doPipe(Message message, PipeLineSession session)
PipeRunResult	XmlBuilderPipe.doPipe(Message message, PipeLineSession session)	Deprecated.
PipeRunResult	XmlIf.doPipe(Message message, PipeLineSession session)
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	XmlValidator.ResponseValidatorWrapper.doPipe(Message message, PipeLineSession session)
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 IteratingPipe.StopReason	XmlFileElementIteratorPipe.iterateOverInput(Message input, PipeLineSession session, Map<String,Object> threadContext, IteratingPipe<String>.ItemCallback callback)	Deprecated.
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)
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 PipeForward	JsonValidator.validate(Message messageToValidate, PipeLineSession session, boolean responseMode, String messageRoot)
PipeRunResult	ValidatorBase.ResponseValidatorWrapper.validate(Message message, PipeLineSession session, String messageRoot)
protected final PipeForward	ValidatorBase.validate(String messageToValidate, PipeLineSession session)
protected abstract PipeForward	ValidatorBase.validate(Message messageToValidate, PipeLineSession session, boolean responseMode, String messageRoot)
PipeRunResult	ValidatorBase.validate(Message message, PipeLineSession session, String messageRoot)
protected PipeForward	WsdlXmlValidator.validate(Message messageToValidate, PipeLineSession session, boolean responseMode, String messageRoot)
PipeRunResult	XmlValidator.ResponseValidatorWrapper.validate(Message message, PipeLineSession session, 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)
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)
PipeRunResult	PipeProcessorBase.processPipe(PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession pipeLineSession)
protected abstract PipeRunResult	PipeProcessorBase.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(SenderWrapperBase senderWrapperBase, Message message, PipeLineSession session)
SenderResult	CoreSenderWrapperProcessor.sendMessage(SenderWrapperBase senderWrapperBase, Message message, PipeLineSession session)
SenderResult	InputOutputSenderWrapperProcessor.sendMessage(SenderWrapperBase senderWrapperBase, Message message, PipeLineSession session)
SenderResult	SenderWrapperProcessor.sendMessage(SenderWrapperBase senderWrapperBase, Message message, PipeLineSession session)
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)
PipeRunResult	PipeProcessorBase.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	FileRecordListener.afterMessageProcessed(PipeLineResult processResult, RawMessageWrapper<String> rawMessage, PipeLineSession pipeLineSession)	Deprecated.
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.
void	Receiver.processRawMessage(IListener<M> origin, RawMessageWrapper<M> rawMessage, PipeLineSession session, boolean duplicatesAlreadyChecked)
void	Receiver.processRawMessage(IListener<M> origin, RawMessageWrapper<M> rawMessage, PipeLineSession session, long waitingDuration, boolean duplicatesAlreadyChecked)
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 Receiver.processRequest(IListener, RawMessageWrapper, Message, PipeLineSession).
Message	ServiceClient.processRequest(Message message, PipeLineSession session)	Method to implement for processing a request.
RawMessageWrapper<M>	JavaListener.wrapRawMessage(M rawMessage, PipeLineSession session)

Uses of PipeLineSession in org.frankframework.scheduler

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

Modifier and Type	Method	Description
SenderResult	SchedulerSender.sendMessage(Message message, 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, ThreadConnector threadConnector, PipeLineSession session, TransformerPool poolToUse, ContentHandler handler, File tempFile)
protected ContentHandler	XsltSender.createHandler(Message input, ThreadConnector threadConnector, PipeLineSession session, TransformerPool poolToUse, ContentHandler handler, File tempFile)
SenderResult	ParallelSenders.doSendMessage(Message message, PipeLineSession session)
SenderResult	ReconnectSenderWrapper.doSendMessage(Message message, PipeLineSession session)
SenderResult	SenderSeries.doSendMessage(Message message, PipeLineSession session)
SenderResult	SenderWrapper.doSendMessage(Message message, PipeLineSession session)
abstract SenderResult	SenderWrapperBase.doSendMessage(Message message, PipeLineSession session)
protected void	ShadowSender.executeGuarded(ISender sender, Message message, PipeLineSession session, Phaser guard, Map<ISender,ParallelSenderExecutor> executorMap)
MailSenderBase.MailSessionBase	MailSenderBase.extract(Message input, PipeLineSession session)	Reads fields from either paramList or Xml file
protected ContentHandler	XsltSender.filterInput(ContentHandler input, PipeLineSession session)
protected ParameterValueList	SenderWithParametersBase.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	BlockEnabledSenderBase.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	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	MailSenderBase.sendMessage(Message message, PipeLineSession session)
SenderResult	ReloadSender.sendMessage(Message message, PipeLineSession session)
SenderResult	SenderWrapperBase.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)
	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, String requester)
void	Message.closeOnCloseOf(PipeLineSession session, INamedObject requester)
static MessageOutputStream	MessageOutputStream.getTargetStream(INamedObject owner, PipeLineSession session, IForwardTarget next)	Provides a non-null MessageOutputStream, that the caller can use to obtain a Writer, OutputStream or ContentHandler.
boolean	Message.isScheduledForCloseOnExitOf(PipeLineSession session)
void	Message.unscheduleFromCloseOnExitOf(PipeLineSession session)

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

Modifier	Constructor	Description
	MessageOutputStream(INamedObject owner, JsonEventHandler handler, MessageOutputStream nextStream, ThreadLifeCycleEventListener<T> threadLifeCycleEventListener, IThreadConnectableTransactionManager txManager, PipeLineSession session, ThreadConnector<?> targetThreadConnector)
	MessageOutputStream(INamedObject owner, ContentHandler handler, MessageOutputStream nextStream, ThreadLifeCycleEventListener<T> threadLifeCycleEventListener, IThreadConnectableTransactionManager txManager, PipeLineSession session, ThreadConnector<?> targetThreadConnector)
	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(IAdapter adapter, String messageId, 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, ValidationContext context)
ValidationContext	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(ValidationContext 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, ValidationContext context)
ValidatorHandler	JavaxXmlValidator.getValidatorHandler(PipeLineSession session, ValidationContext context)
ValidatorHandler	XercesXmlValidator.getValidatorHandler(PipeLineSession session, ValidationContext context)
AbstractXmlValidator.ValidationResult	AbstractXmlValidator.validate(Object input, PipeLineSession session, String logPrefix, RootValidations rootValidations, Map<List<String>,List<String>> invalidRootNamespaces)
AbstractXmlValidator.ValidationResult	AbstractXmlValidator.validate(Object input, PipeLineSession session, ValidatorHandler validatorHandler, XMLFilterImpl filter, ValidationContext context)
AbstractXmlValidator.ValidationResult	AbstractXmlValidator.validate(InputSource inputSource, ValidatorHandler validatorHandler, PipeLineSession session, ValidationContext 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)