Uses of Class
org.frankframework.core.PipeLineSession
Packages that use PipeLineSession
Package
Description
-
Uses of PipeLineSession in org.frankframework.batch
Methods in org.frankframework.batch with parameters of type PipeLineSessionModifier and TypeMethodDescriptionprotected void
StreamTransformerPipe.closeAllBlocks
(PipeLineSession session, String streamId, IResultHandler handler, Map<String, Object> blocks) Deprecated.void
IResultHandler.closeBlock
(PipeLineSession session, String streamId, String blockName, Map<String, Object> blocks) void
ResultBlock2Sender.closeBlock
(PipeLineSession session, String streamId, String blockName, Map<String, Object> blocks) Deprecated.void
ResultWriter.closeBlock
(PipeLineSession session, String streamId, String blockName, Map<String, Object> blocks) void
AbstractResultHandler.closeDocument
(PipeLineSession session, String streamId) void
IResultHandler.closeDocument
(PipeLineSession session, String streamId) void
Result2Filewriter.closeDocument
(PipeLineSession session, String streamId) Deprecated.void
ResultBlock2Sender.closeDocument
(PipeLineSession session, String streamId) Deprecated.void
ResultWriter.closeDocument
(PipeLineSession session, String streamId) void
IResultHandler.closeRecordType
(PipeLineSession session, String streamId) void
ResultWriter.closeRecordType
(PipeLineSession session, String streamId) protected Writer
Result2Filewriter.createWriter
(PipeLineSession session, String streamId) Deprecated.protected Writer
Result2StringWriter.createWriter
(PipeLineSession session, String streamId) Deprecated.protected abstract Writer
ResultWriter.createWriter
(PipeLineSession session, String streamId) BatchFileTransformerPipe.doPipe
(Message input, PipeLineSession session) Deprecated.Open a reader for the file named according the input message and transform it.StreamTransformerPipe.doPipe
(Message input, PipeLineSession session) Deprecated.Open a reader for the file named according the input messsage and transform it.IResultHandler.finalizeResult
(PipeLineSession session, String streamId, boolean error) Called when all records in the original file are handled.Result2Filewriter.finalizeResult
(PipeLineSession session, String streamId, boolean error) Deprecated.Result2StringWriter.finalizeResult
(PipeLineSession session, String streamId, boolean error) Deprecated.ResultWriter.finalizeResult
(PipeLineSession session, String streamId, boolean error) protected InputStream
BatchFileTransformerPipe.getInputStream
(String streamId, Message input, PipeLineSession session) Deprecated.protected InputStream
StreamTransformerPipe.getInputStream
(String streamId, Message input, PipeLineSession session) Deprecated.DelphiStringRecordReaderFactory.getReader
(InputStream in, String charset, String streamId, PipeLineSession session) Deprecated.InputStreamReaderFactory.getReader
(InputStream inputstream, String charset, String streamId, PipeLineSession session) IReaderFactory.getReader
(InputStream inputstream, String charset, String streamId, PipeLineSession session) Obtain a Reader that reads lines in the given characterset.protected BufferedReader
StreamTransformerPipe.getReader
(String streamId, Message input, PipeLineSession session) Deprecated.IRecordHandlerManager.getRecordFactoryUsingFilename
(PipeLineSession session, String filename) RecordHandlerManager.getRecordFactoryUsingFilename
(PipeLineSession session, String inputFilename) Deprecated.FieldPositionRecordHandlerManager.getRecordHandler
(PipeLineSession session, String record) Deprecated.FixedPositionRecordHandlerManager.getRecordHandler
(PipeLineSession session, String record) Deprecated.IRecordHandlerManager.getRecordHandler
(PipeLineSession session, String record) RecordHandlerManager.getRecordHandler
(PipeLineSession session, String record) Deprecated.protected String
BatchFileTransformerPipe.getStreamId
(Message input, PipeLineSession session) Deprecated.protected String
StreamTransformerPipe.getStreamId
(Message input, PipeLineSession session) Deprecated.protected Writer
ResultWriter.getWriter
(PipeLineSession session, String streamId, boolean create) IRecordHandler.handleRecord
(PipeLineSession session, List<String> parsedRecord) Perform an action on the array of fields.RecordTransformer.handleRecord
(PipeLineSession session, List<String> parsedRecord) Deprecated.RecordXml2Sender.handleRecord
(PipeLineSession session, List<String> parsedRecord) Deprecated.RecordXmlTransformer.handleRecord
(PipeLineSession session, List<String> parsedRecord) Deprecated.void
IResultHandler.handleResult
(PipeLineSession session, String streamId, String recordKey, String result) write a result record.void
ResultWriter.handleResult
(PipeLineSession session, String streamId, String recordKey, String result) boolean
AbstractRecordHandler.isNewRecordType
(PipeLineSession session, boolean equalRecordHandlers, List<String> prevRecord, List<String> curRecord) Deprecated.boolean
IRecordHandler.isNewRecordType
(PipeLineSession session, boolean equalRecordTypes, List<String> prevRecord, List<String> curRecord) void
IResultHandler.openBlock
(PipeLineSession session, String streamId, String blockName, Map<String, Object> blocks) void
ResultBlock2Sender.openBlock
(PipeLineSession session, String streamId, String blockName, Map<String, Object> blocks) Deprecated.void
ResultWriter.openBlock
(PipeLineSession session, String streamId, String blockName, Map<String, Object> blocks) void
AbstractResultHandler.openDocument
(PipeLineSession session, String streamId) void
IResultHandler.openDocument
(PipeLineSession session, String streamId) Called once, before the first record of a stream is presented to handleResult.void
ResultBlock2Sender.openDocument
(PipeLineSession session, String streamId) Deprecated.void
ResultWriter.openDocument
(PipeLineSession session, String streamId) void
IResultHandler.openRecordType
(PipeLineSession session, String streamId) void
ResultWriter.openRecordType
(PipeLineSession session, String streamId) AbstractRecordHandler.parse
(PipeLineSession session, String record) Deprecated.IRecordHandler.parse
(PipeLineSession session, String record) Parse the line into an array of fields. -
Uses of PipeLineSession in org.frankframework.cache
Methods in org.frankframework.cache with parameters of type PipeLineSessionModifier and TypeMethodDescriptionRemoveCacheKeyPipe.doPipe
(Message message, PipeLineSession session) AbstractCacheAdapter.transformKey
(String input, PipeLineSession session) ICache.transformKey
(String input, PipeLineSession session) Transform the the current request message to a key in the cache-map.AbstractCacheAdapter.transformValue
(Message value, PipeLineSession session) 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 PipeLineSessionModifier and TypeMethodDescriptionvoid
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) ICollector.createPart
(Message input, PipeLineSession session, ParameterValueList pvl) Add a single item to the collectionprotected final Message
AbstractCollectorPipe.doAction
(AbstractCollectorPipe.Action action, Message input, PipeLineSession session) 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) AbstractCollectorSender.sendMessage
(Message message, PipeLineSession session) -
Uses of PipeLineSession in org.frankframework.compression
Methods in org.frankframework.compression with parameters of type PipeLineSessionModifier and TypeMethodDescriptionprotected ZipWriter
ZipWriterPipe.createCollector
(Message input, PipeLineSession session) ZipWriter.createPart
(Message input, PipeLineSession session, ParameterValueList pvl) ZipWriterPipe.doPipe
(Message input, PipeLineSession session) protected IDataIterator
<String> ZipIteratorPipe.getIterator
(Message input, PipeLineSession session, Map<String, Object> threadContext) ZipWriterSender.sendMessage
(Message message, PipeLineSession session) -
Uses of PipeLineSession in org.frankframework.core
Methods in org.frankframework.core with parameters of type PipeLineSessionModifier and TypeMethodDescriptionvoid
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 byIBlockEnabledSender.openBlock(PipeLineSession)
.AbstractResponseValidatorWrapper.doPipe
(Message message, PipeLineSession session) IPipe.doPipe
(Message message, PipeLineSession session) This is where the action takes place.void
PipeLineSession.mergeToParentSession
(String keysToCopy, PipeLineSession parentSession) IBlockEnabledSender.openBlock
(PipeLineSession session) open a resource that can be used multiple times whenIBlockEnabledSender.sendMessage(Object, Message, PipeLineSession)
is called.PipeLine.process
(String messageId, Message message, PipeLineSession pipeLineSession) Theprocess
method does the processing of a message.
It retrieves the first pipe to execute from thefirstPipe
field, the call results in a PipRunResult, containing the next pipe to activate.Adapter.processMessageDirect
(String messageId, Message message, PipeLineSession pipeLineSession) Direct call to the Adapter PipeLine, foregoing any listeners and receivers.Adapter.processMessageWithExceptions
(String messageId, Message message, PipeLineSession pipeLineSession) This method does the real processing of messages by the adapter.void
IMessageHandler.processRawMessage
(IListener<M> origin, RawMessageWrapper<M> message, PipeLineSession session, boolean duplicatesAlreadyChecked) Will use listener to performIListener.extractMessage(org.frankframework.receivers.RawMessageWrapper<M>, java.util.Map<java.lang.String, java.lang.Object>)
andIListener.afterMessageProcessed(org.frankframework.core.PipeLineResult, org.frankframework.receivers.RawMessageWrapper<M>, org.frankframework.core.PipeLineSession)
IMessageHandler.processRequest
(IListener<M> origin, RawMessageWrapper<M> rawMessage, Message message, PipeLineSession session) Alternative to functions above, will NOT useIListener.extractMessage(org.frankframework.receivers.RawMessageWrapper<M>, java.util.Map<java.lang.String, java.lang.Object>)
.IBlockEnabledSender.sendMessage
(H blockHandle, Message message, PipeLineSession session) ISender.sendMessage
(Message message, PipeLineSession session) Send a message to some destination (as configured in the Sender object).default Message
ISender.sendMessageOrThrow
(Message message, PipeLineSession session) AbstractResponseValidatorWrapper.validate
(Message message, PipeLineSession session, String messageRoot) IValidator.validate
(Message message, PipeLineSession session, String messageRoot) IPushingListener.wrapRawMessage
(M rawMessage, PipeLineSession session) Wrap a raw message in a MessageWrapper. -
Uses of PipeLineSession in org.frankframework.extensions.afm
Methods in org.frankframework.extensions.afm with parameters of type PipeLineSessionModifier and TypeMethodDescriptionAfm2EdiFactSender.sendMessage
(Message message, PipeLineSession session) -
Uses of PipeLineSession in org.frankframework.extensions.akamai
Methods in org.frankframework.extensions.akamai with parameters of type PipeLineSessionModifier and TypeMethodDescriptionNetStorageSender.extractResult
(HttpResponseHandler responseHandler, PipeLineSession session) org.apache.http.client.methods.HttpRequestBase
NetStorageSender.getMethod
(URI uri, Message message, ParameterValueList parameters, PipeLineSession session) NetStorageSender.sendMessage
(Message message, PipeLineSession session) -
Uses of PipeLineSession in org.frankframework.extensions.api
Methods in org.frankframework.extensions.api with parameters of type PipeLineSessionModifier and TypeMethodDescriptionprotected String
ApiStreamPipe.adjustFirstStringPart
(String firstStringPart, PipeLineSession session) Deprecated. -
Uses of PipeLineSession in org.frankframework.extensions.aspose.pipe
Methods in org.frankframework.extensions.aspose.pipe with parameters of type PipeLineSessionModifier and TypeMethodDescriptionAmountOfPagesPipe.doPipe
(Message input, PipeLineSession session) PdfPipe.doPipe
(Message input, PipeLineSession session) -
Uses of PipeLineSession in org.frankframework.extensions.bis
Methods in org.frankframework.extensions.bis with parameters of type PipeLineSessionModifier and TypeMethodDescriptionBisWrapperPipe.doPipe
(Message message, PipeLineSession session) Deprecated.BisJmsSender.sendMessage
(Message input, PipeLineSession session) Deprecated. -
Uses of PipeLineSession in org.frankframework.extensions.cmis
Methods in org.frankframework.extensions.cmis with parameters of type PipeLineSessionModifier and TypeMethodDescriptionCmisHttpSender.extractResult
(HttpResponseHandler responseHandler, PipeLineSession session) org.apache.http.client.methods.HttpRequestBase
CmisHttpSender.getMethod
(URI uri, Message message, ParameterValueList pvl, PipeLineSession session) static void
CmisUtils.populateCmisAttributes
(PipeLineSession session) CmisSender.sendMessage
(Message message, PipeLineSession session) static org.apache.chemistry.opencmis.commons.data.ObjectData
CmisUtils.xml2ObjectData
(Element cmisElement, PipeLineSession context) static org.apache.chemistry.opencmis.commons.data.ObjectList
CmisUtils.xml2ObjectList
(Element result, PipeLineSession context) -
Uses of PipeLineSession in org.frankframework.extensions.cmis.server
Methods in org.frankframework.extensions.cmis.server with parameters of type PipeLineSessionModifier and TypeMethodDescriptionCmisEventDispatcher.trigger
(CmisEvent event, String message, PipeLineSession messageContext) -
Uses of PipeLineSession in org.frankframework.extensions.esb
Methods in org.frankframework.extensions.esb with parameters of type PipeLineSessionModifier and TypeMethodDescriptionvoid
EsbJmsListener.afterMessageProcessed
(PipeLineResult plr, RawMessageWrapper<jakarta.jms.Message> rawMessageWrapper, PipeLineSession pipeLineSession) WsdlGeneratorPipe.doPipe
(Message message, PipeLineSession session) DirectWrapperPipe.doPipeWithTimeoutGuarded
(Message message, PipeLineSession session) EsbJmsListener.getMessageProperties
(PipeLineSession session) -
Uses of PipeLineSession in org.frankframework.extensions.fxf
Methods in org.frankframework.extensions.fxf with parameters of type PipeLineSessionModifier and TypeMethodDescriptionvoid
FxfListener.afterMessageProcessed
(PipeLineResult plr, RawMessageWrapper<jakarta.jms.Message> rawMessageWrapper, PipeLineSession pipeLineSession) FxfWrapperPipe.doPipe
(Message message, PipeLineSession session) -
Uses of PipeLineSession in org.frankframework.extensions.idin
Methods in org.frankframework.extensions.idin with parameters of type PipeLineSessionModifier and TypeMethodDescriptionprotected net.bankid.merchant.library.Communicator
IdinSender.createCommunicator
(PipeLineSession session) IdinSender.sendMessage
(Message message, PipeLineSession session) -
Uses of PipeLineSession in org.frankframework.extensions.kafka
Methods in org.frankframework.extensions.kafka with parameters of type PipeLineSessionModifier and TypeMethodDescriptionvoid
KafkaListener.afterMessageProcessed
(PipeLineResult processResult, RawMessageWrapper<org.apache.kafka.clients.consumer.ConsumerRecord<String, byte[]>> rawMessage, PipeLineSession pipeLineSession) Deprecated.KafkaSender.sendMessage
(Message message, PipeLineSession session) Deprecated. -
Uses of PipeLineSession in org.frankframework.extensions.mqtt
Methods in org.frankframework.extensions.mqtt with parameters of type PipeLineSessionModifier and TypeMethodDescriptionvoid
MqttListener.afterMessageProcessed
(PipeLineResult processResult, RawMessageWrapper<org.eclipse.paho.client.mqttv3.MqttMessage> rawMessage, PipeLineSession pipeLineSession) MqttSender.sendMessage
(Message message, PipeLineSession session) RawMessageWrapper
<org.eclipse.paho.client.mqttv3.MqttMessage> MqttListener.wrapRawMessage
(org.eclipse.paho.client.mqttv3.MqttMessage message, PipeLineSession session) -
Uses of PipeLineSession in org.frankframework.extensions.rekenbox
Methods in org.frankframework.extensions.rekenbox with parameters of type PipeLineSessionModifier and TypeMethodDescriptionAdios2XmlPipe.doPipe
(Message message, PipeLineSession session) LabelFormat.doPipe
(Message message, PipeLineSession session) RekenBoxCaller.doPipe
(Message message, PipeLineSession session) positie 1 t/m 8 bepalen de naam van de executable, of tot aan de ':' (wat het eerst komt)Adios2XmlPipe.findRekenbox
(PipeLineSession session) Adios2XmlPipe.makeAdios
(InputSource bericht, PipeLineSession session) Adios2XmlPipe.makeXml
(String s, PipeLineSession session) The calcbox tool Adios exports the file "NNRSCONS.PAS" = adiosDefinities in configuration attributes. -
Uses of PipeLineSession in org.frankframework.extensions.sap.jco3
Methods in org.frankframework.extensions.sap.jco3 with parameters of type PipeLineSessionModifier and TypeMethodDescriptionvoid
SapListenerImpl.afterMessageProcessed
(PipeLineResult processResult, RawMessageWrapper<M> rawMessageWrapper, PipeLineSession pipeLineSession) static SapLUWHandle
SapLUWHandle.createHandle
(PipeLineSession session, String sessionKey, SapSystemImpl sapSystem, boolean useTid) SapLUWManager.doPipe
(Message message, PipeLineSession session) com.sap.conn.jco.JCoDestination
SapSenderBase.getDestination
(PipeLineSession session, SapSystemImpl sapSystem) static void
SapLUWHandle.releaseHandle
(PipeLineSession session, String sessionKey) static SapLUWHandle
SapLUWHandle.retrieveHandle
(PipeLineSession session, String sessionKey) static SapLUWHandle
SapLUWHandle.retrieveHandle
(PipeLineSession session, String sessionKey, boolean create, SapSystemImpl sapSystem, boolean useTid) IdocSenderImpl.sendMessage
(Message message, PipeLineSession session) SapSenderImpl.sendMessage
(Message message, PipeLineSession session) SapListenerImpl.wrapRawMessage
(M message, PipeLineSession session) -
Uses of PipeLineSession in org.frankframework.extensions.svn
Methods in org.frankframework.extensions.svn with parameters of type PipeLineSessionModifier and TypeMethodDescriptionScanTibcoSolutionPipe.doPipe
(Message message, PipeLineSession session) -
Uses of PipeLineSession in org.frankframework.extensions.tibco
Methods in org.frankframework.extensions.tibco with parameters of type PipeLineSessionModifier and TypeMethodDescriptionGetTibcoQueues.doPipeWithTimeoutGuarded
(Message input, PipeLineSession session) SendTibcoMessage.doPipeWithTimeoutGuarded
(Message input, PipeLineSession session) -
Uses of PipeLineSession in org.frankframework.extensions.tibco.pipes
Methods in org.frankframework.extensions.tibco.pipes with parameters of type PipeLineSession -
Uses of PipeLineSession in org.frankframework.extensions.xfb
Methods in org.frankframework.extensions.xfb with parameters of type PipeLineSessionModifier and TypeMethodDescriptionXfbSender.sendMessage
(Message message, PipeLineSession session) -
Uses of PipeLineSession in org.frankframework.filesystem
Methods in org.frankframework.filesystem with parameters of type PipeLineSessionModifier and TypeMethodDescriptionvoid
AbstractFileSystemListener.afterMessageProcessed
(PipeLineResult processResult, RawMessageWrapper<F> rawMessage, PipeLineSession pipeLineSession) FileSystemActor.doAction
(Message input, ParameterValueList pvl, PipeLineSession session) AbstractFileSystemPipe.doPipe
(Message message, PipeLineSession session) protected Message
MsalClientAdapter.extractResult
(HttpResponseHandler responseHandler, PipeLineSession session) protected IDataIterator
<A> ForEachAttachmentPipe.getIterator
(Message message, PipeLineSession session, Map<String, Object> threadContext) protected org.apache.http.client.methods.HttpRequestBase
MsalClientAdapter.getMethod
(URI uri, Message message, ParameterValueList parameters, PipeLineSession session) AbstractFileSystemSender.sendMessage
(Message message, PipeLineSession session) FileSystemSenderWithAttachments.sendMessage
(Message message, PipeLineSession session) Deprecated. -
Uses of PipeLineSession in org.frankframework.http
Methods in org.frankframework.http with parameters of type PipeLineSessionModifier and TypeMethodDescriptionvoid
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 contentRestServiceDispatcher.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 aHttpRequest
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) PushingListenerAdapter.processRequest
(Message rawMessage, PipeLineSession session) RestListener.processRequest
(Message message, PipeLineSession session) WebServiceListener.processRequest
(Message message, PipeLineSession session) static String
RestListenerUtils.retrieveRequestURL
(PipeLineSession session) AbstractHttpSender.sendMessage
(Message message, PipeLineSession session) WebServiceNtlmSender.sendMessage
(Message message, PipeLineSession session) Deprecated, for removal: This API element is subject to removal in a future version.static void
RestListenerUtils.setResponseContentType
(PipeLineSession session, String contentType) Deprecated.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 PipeLineSessionModifier and TypeMethodDescriptionorg.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 PipeLineSessionModifier and TypeMethodDescriptionApiPrincipalPipe.doPipe
(Message message, PipeLineSession session) -
Uses of PipeLineSession in org.frankframework.javascript
Methods in org.frankframework.javascript with parameters of type PipeLineSessionModifier and TypeMethodDescriptionvoid
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 PipeLineSessionModifier and TypeMethodDescriptionvoid
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 Writer
Result2LobWriterBase.createWriter
(PipeLineSession session, String streamId) 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) Result2LobWriterBase.finalizeResult
(PipeLineSession session, String streamId, boolean error) protected IDataIterator
<String> JdbcIteratingPipeBase.getIterator
(Message message, PipeLineSession session, Map<String, Object> threadContext) protected Reader
BatchBlobTransformerPipe.getReader
(ResultSet rs, String charset, String streamId, PipeLineSession session) Deprecated.protected Reader
BatchClobTransformerPipe.getReader
(ResultSet rs, String charset, String streamId, PipeLineSession session) Deprecated.protected BufferedReader
BatchTransformerPipeBase.getReader
(String streamId, Message message, PipeLineSession session) Deprecated.protected abstract Reader
BatchTransformerPipeBase.getReader
(ResultSet rs, String charset, String streamId, PipeLineSession session) Deprecated.DirectQuerySender.openBlock
(PipeLineSession session) FixedQuerySender.openBlock
(PipeLineSession session) final SenderResult
AbstractJdbcSender.sendMessage
(Message message, PipeLineSession session) DirectQuerySender.sendMessage
(Connection connection, Message message, PipeLineSession session) FixedQuerySender.sendMessage
(QueryExecutionContext blockHandle, Message message, PipeLineSession session) MessageStoreSender.sendMessage
(Message message, PipeLineSession session) XmlQuerySender.sendMessage
(Connection blockHandle, Message message, PipeLineSession session) -
Uses of PipeLineSession in org.frankframework.jms
Methods in org.frankframework.jms with parameters of type PipeLineSessionModifier and TypeMethodDescriptionvoid
AbstractJmsListener.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) AbstractJmsListener.getMessageProperties
(PipeLineSession session) Set additional message headers/properties on the JMS response, read after message has been processed!JmsSender.sendMessage
(Message message, PipeLineSession session) JmsSender.sendMessage
(Message message, PipeLineSession pipeLineSession, String soapHeader) XmlJmsBrowserSender.sendMessage
(Message message, PipeLineSession session) protected void
AbstractJmsListener.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.ladybug
Methods in org.frankframework.ladybug that return PipeLineSessionModifier and TypeMethodDescriptionstatic PipeLineSession
PipeLineSessionDebugger.newInstance
(PipeLineSession pipeLineSession, LadybugReportGenerator ibisDebugger) Methods in org.frankframework.ladybug with parameters of type PipeLineSessionModifier and TypeMethodDescriptionIbisDebuggerAdvice.debugBlockEnabledSenderInputOutputAbort
(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint, Object blockHandle, Message message, PipeLineSession session) IbisDebuggerAdvice.debugParameterResolvedTo
(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint, ParameterValueList alreadyResolvedParameters, Message message, PipeLineSession session, boolean namespaceAware) IbisDebuggerAdvice.debugPipeGetInputFrom
(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint, PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession session) Provides advice forLimitingParallelExecutionPipeProcessor.processPipe(PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession session)
LimitingParallelExecutionPipeProcessor is just after InputOutputPipeProcessor, so it sees the effect of the replacements made by the latter.IbisDebuggerAdvice.debugPipeInputOutputAbort
(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint, PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession session) IbisDebuggerAdvice.debugPipeLineInputOutputAbort
(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint, PipeLine pipeLine, String messageId, Message message, PipeLineSession session) <M> M
IbisDebuggerAdvice.debugReplyListenerInputOutputAbort
(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint, ICorrelatedPullingListener<M> listener, String correlationId, PipeLineSession pipeLineSession) IbisDebuggerAdvice.debugSenderGetInputFrom
(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint, AbstractSenderWrapper senderWrapperBase, Message message, PipeLineSession session) IbisDebuggerAdvice.debugSenderSendMessage
(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint, Message message, PipeLineSession session) Provides advice forISender.sendMessage(Message message, PipeLineSession session)
IbisDebuggerAdvice.debugSenderSendMessageOrThrow
(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint, Message message, PipeLineSession session) Provides advice forISender.sendMessageOrThrow(Message message, PipeLineSession session)
IbisDebuggerAdvice.debugValidatorInputOutputAbort
(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint, PipeLine pipeLine, IValidator validator, Message message, PipeLineSession session, String messageRoot) LadybugPipe.doPipe
(Message message, PipeLineSession session) IbisDebuggerAdvice.getCorrelationId
(PipeLineSession session) IbisDebuggerAdvice.inspectXml
(PipeLineSession session, String label, ContentHandler contentHandler) static PipeLineSession
PipeLineSessionDebugger.newInstance
(PipeLineSession pipeLineSession, LadybugReportGenerator ibisDebugger) -
Uses of PipeLineSession in org.frankframework.larva
Methods in org.frankframework.larva with parameters of type PipeLineSessionModifier and TypeMethodDescriptionvoid
ListenerMessageHandler.processRawMessage
(IListener<M> origin, RawMessageWrapper<M> rawMessage, PipeLineSession threadContext, boolean duplicatesAlreadyChecked) ListenerMessageHandler.processRequest
(IListener<M> origin, RawMessageWrapper<M> rawMessage, Message message, PipeLineSession session) Constructors in org.frankframework.larva with parameters of type PipeLineSessionModifierConstructorDescriptionListenerMessage
(Message message, PipeLineSession context) SenderThread
(ISender sender, Message request, PipeLineSession session, boolean convertExceptionToMessage, String correlationId) -
Uses of PipeLineSession in org.frankframework.larva.actions
Methods in org.frankframework.larva.actions with parameters of type PipeLineSessionModifier and TypeMethodDescriptionstatic Map
<String, IParameter> LarvaActionUtils.createParametersMapFromParamProperties
(Properties properties, PipeLineSession session) Create a Map for a specific property based on other properties that are the same except for a .param1.name, .param1.value or .param1.valuefile suffix. -
Uses of PipeLineSession in org.frankframework.ldap
Methods in org.frankframework.ldap with parameters of type PipeLineSessionModifier and TypeMethodDescriptionAbstractLdapQueryPipe.doPipe
(Message message, PipeLineSession session) abstract PipeRunResult
AbstractLdapQueryPipe.doPipeWithException
(Message message, PipeLineSession session) LdapFindGroupMembershipsPipe.doPipeWithException
(Message message, PipeLineSession session) 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.LdapSender.performOperation
(Message message, PipeLineSession session) Performs the specified operation and returns the results.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 PipeLineSessionModifier and TypeMethodDescriptionMongoDbSender.sendMessage
(Message message, PipeLineSession session) -
Uses of PipeLineSession in org.frankframework.parameters
Methods in org.frankframework.parameters with parameters of type PipeLineSessionModifier and TypeMethodDescriptionstatic ParameterValueList
ParameterValueList.get
(ParameterList params, Message message, PipeLineSession session) AbstractParameter.getValue
(ParameterValueList alreadyResolvedParameters, Message message, PipeLineSession session, boolean namespaceAware) determines the raw valueIParameter.getValue
(ParameterValueList alreadyResolvedParameters, Message message, PipeLineSession session, boolean namespaceAware) NumberParameter.getValue
(ParameterValueList alreadyResolvedParameters, Message message, PipeLineSession session, boolean namespaceAware) ParameterList.getValue
(ParameterValueList alreadyResolvedParameters, IParameter p, Message message, PipeLineSession session, boolean namespaceAware) ParameterList.getValues
(Message message, PipeLineSession session) 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 PipeLineSessionModifier and TypeMethodDescriptionprotected 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 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) AbstractValidator.doPipe
(Message input, PipeLineSession session, boolean responseMode, String messageRoot) Base64Pipe.doPipe
(Message message, PipeLineSession session) BytesOutputPipe.doPipe
(Message message, PipeLineSession session) ChecksumPipe.doPipe
(Message message, PipeLineSession session) Deprecated, for removal: This API element is subject to removal in a future version.CompareIntegerPipe.doPipe
(Message message, PipeLineSession session) CompareStringPipe.doPipe
(Message message, PipeLineSession session) CompressPipe.doPipe
(Message message, PipeLineSession session) CounterSwitchPipe.doPipe
(Message message, PipeLineSession session) CredentialCheckingPipe.doPipe
(Message message, PipeLineSession session) CrlPipe.doPipe
(Message message, PipeLineSession session) CsvParserPipe.doPipe
(Message message, PipeLineSession session) DataSonnetPipe.doPipe
(Message message, PipeLineSession session) DelayPipe.doPipe
(Message message, PipeLineSession session) DomainTransformerPipe.doPipe
(Message invoer, PipeLineSession session) EchoPipe.doPipe
(Message message, PipeLineSession session) EscapePipe.doPipe
(Message message, PipeLineSession session) EtagHandlerPipe.doPipe
(Message message, PipeLineSession session) Deprecated.ExceptionPipe.doPipe
(Message message, PipeLineSession session) FixedResultPipe.doPipe
(Message message, PipeLineSession session) ForPipe.doPipe
(Message message, PipeLineSession session) GetFromSession.doPipe
(Message message, PipeLineSession session) GetPrincipalPipe.doPipe
(Message message, PipeLineSession session) HashPipe.doPipe
(Message message, PipeLineSession session) IfPipe.doPipe
(Message message, PipeLineSession session) IncreaseIntegerPipe.doPipe
(Message message, PipeLineSession session) IsUserInRolePipe.doPipe
(Message message, PipeLineSession session) IsXmlPipe.doPipe
(Message message, PipeLineSession session) 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.JsonPipe.doPipe
(Message message, PipeLineSession session) JsonWellFormedChecker.doPipe
(Message message, PipeLineSession session) JwtPipe.doPipe
(Message message, PipeLineSession session) LarvaPipe.doPipe
(Message message, PipeLineSession session) LogContextPipe.doPipe
(Message message, PipeLineSession session) MessageSendingPipe.doPipe
(Message input, PipeLineSession session) PasswordGeneratorPipe.doPipe
(Message message, PipeLineSession session) PasswordHashPipe.doPipe
(Message message, PipeLineSession session) PGPPipe.doPipe
(Message message, PipeLineSession session) PutInSession.doPipe
(Message message, PipeLineSession session) PutSystemDateInSession.doPipe
(Message message, PipeLineSession session) RegExPipe.doPipe
(Message message, PipeLineSession session) RemoveFromSession.doPipe
(Message message, PipeLineSession session) ReplacerPipe.doPipe
(Message message, PipeLineSession session) SignaturePipe.doPipe
(Message message, PipeLineSession session) SizePipe.doPipe
(Message message, PipeLineSession session) SkipPipe.doPipe
(Message message, PipeLineSession session) StreamPipe.doPipe
(Message message, PipeLineSession session) Text2XmlPipe.doPipe
(Message message, PipeLineSession session) TextSplitterPipe.doPipe
(Message message, PipeLineSession session) TimeoutGuardPipe.doPipe
(Message message, PipeLineSession session) UnzipPipe.doPipe
(Message message, PipeLineSession session) UUIDGeneratorPipe.doPipe
(Message message, PipeLineSession session) WsdlGeneratorPipe.doPipe
(Message message, PipeLineSession session) XmlIf.doPipe
(Message message, PipeLineSession session) Deprecated, for removal: This API element is subject to removal in a future version.XmlSwitch.doPipe
(Message message, PipeLineSession session) This is where the action takes place, the switching is done.XmlValidator.doPipe
(Message input, PipeLineSession session, boolean responseMode, String messageRoot) XmlWellFormedChecker.doPipe
(Message message, PipeLineSession session) XQueryPipe.doPipe
(Message message, PipeLineSession session) XsltPipe.doPipe
(Message input, PipeLineSession session) abstract PipeRunResult
TimeoutGuardPipe.doPipeWithTimeoutGuarded
(Message input, PipeLineSession session) doPipe wrapped around a TimeoutGuardprotected 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) Json2XmlValidator.getOutputFormat
(PipeLineSession session, boolean responseMode) protected Reader
StreamLineIteratorPipe.getReader
(Message input, PipeLineSession session, Map<String, Object> threadContext) XmlValidator.getSchemas
(PipeLineSession session) 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 byInputOutputPipeProcessor
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) 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) XmlWellFormedChecker.validate
(Message message, PipeLineSession session, String messageRoot) Constructors in org.frankframework.pipes with parameters of type PipeLineSession -
Uses of PipeLineSession in org.frankframework.processors
Methods in org.frankframework.processors with parameters of type PipeLineSessionModifier and TypeMethodDescriptionprotected String
CoreListenerProcessor.getLogPrefix
(ICorrelatedPullingListener<M> listener, PipeLineSession session) CoreListenerProcessor.getMessage
(ICorrelatedPullingListener<M> listener, String correlationID, PipeLineSession pipeLineSession) ListenerProcessor.getMessage
(ICorrelatedPullingListener<M> listener, String correlationID, PipeLineSession pipeLineSession) 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) 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) 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.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) 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) CachePipeLineProcessor.processPipeLine
(PipeLine pipeLine, String messageId, Message message, PipeLineSession pipeLineSession, String firstPipe) CorePipeLineProcessor.processPipeLine
(PipeLine pipeLine, String messageId, Message message, PipeLineSession pipeLineSession, String firstPipe) InputOutputPipeLineProcessor.processPipeLine
(PipeLine pipeLine, String messageId, Message message, PipeLineSession pipeLineSession, String firstPipe) LimitingParallelExecutionPipeLineProcessor.processPipeLine
(PipeLine pipeLine, String messageId, Message message, PipeLineSession pipeLineSession, String firstPipe) LockerPipeLineProcessor.processPipeLine
(PipeLine pipeLine, String messageId, Message message, PipeLineSession pipeLineSession, String firstPipe) PipeLineProcessor.processPipeLine
(PipeLine pipeLine, String messageId, Message message, PipeLineSession pipeLineSession, String firstPipe) TransactionAttributePipeLineProcessor.processPipeLine
(PipeLine pipeLine, String messageId, Message message, PipeLineSession pipeLineSession, String firstPipe) CacheSenderWrapperProcessor.sendMessage
(AbstractSenderWrapper abstractSenderWrapper, Message message, PipeLineSession session) CoreSenderWrapperProcessor.sendMessage
(AbstractSenderWrapper abstractSenderWrapper, Message message, PipeLineSession session) InputOutputSenderWrapperProcessor.sendMessage
(AbstractSenderWrapper abstractSenderWrapper, Message message, PipeLineSession session) SenderWrapperProcessor.sendMessage
(AbstractSenderWrapper abstractSenderWrapper, Message message, PipeLineSession session) AbstractPipeProcessor.validate
(PipeLine pipeLine, IValidator validator, Message message, PipeLineSession pipeLineSession, String messageRoot) CorePipeProcessor.validate
(PipeLine pipeLine, IValidator validator, Message message, PipeLineSession pipeLineSession, String messageRoot) LimitingParallelExecutionPipeProcessor.validate
(PipeLine pipeLine, IValidator validator, Message message, PipeLineSession pipeLineSession, String messageRoot) 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 PipeLineSessionModifier and TypeMethodDescriptionvoid
FrankListener.afterMessageProcessed
(PipeLineResult processResult, RawMessageWrapper<Message> rawMessage, PipeLineSession pipeLineSession) void
JavaListener.afterMessageProcessed
(PipeLineResult processResult, RawMessageWrapper<M> rawMessage, PipeLineSession pipeLineSession) ServiceDispatcher.dispatchRequest
(String serviceName, Message message, PipeLineSession session) Dispatch a requestMessage
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.FrankListener.processRequest
(Message message, PipeLineSession session) JavaListener.processRequest
(Message message, PipeLineSession session) Receiver.processRequest
(IListener<M> origin, RawMessageWrapper<M> rawMessage, Message message, PipeLineSession session) Process the received message withIMessageHandler.processRequest(IListener, RawMessageWrapper, Message, PipeLineSession)
.ServiceClient.processRequest
(Message message, PipeLineSession session) Method to implement for processing a request.FrankListener.wrapRawMessage
(Message rawMessage, PipeLineSession session) JavaListener.wrapRawMessage
(M rawMessage, PipeLineSession session) -
Uses of PipeLineSession in org.frankframework.senders
Methods in org.frankframework.senders with parameters of type PipeLineSessionModifier and TypeMethodDescriptionvoid
IsolatedServiceCaller.callServiceAsynchronous
(ServiceClient service, Message message, PipeLineSession session, ThreadLifeCycleEventListener<?> threadLifeCycleEventListener) 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) ParallelSenders.doSendMessage
(Message message, PipeLineSession session) ReconnectSenderWrapper.doSendMessage
(Message message, PipeLineSession session) SenderSeries.doSendMessage
(Message input, PipeLineSession session) SenderWrapper.doSendMessage
(Message message, PipeLineSession session) protected void
ShadowSender.executeGuarded
(ISender sender, Message message, PipeLineSession session, Phaser guard, Map<ISender, ParallelSenderExecutor> executorMap) AbstractMailSender.extract
(Message input, PipeLineSession session) Reads fields from either paramList or Xml fileprotected 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) AbstractMailSender.sendMessage
(Message message, PipeLineSession session) AbstractSenderWrapper.sendMessage
(Message message, PipeLineSession session) CommandSender.sendMessage
(Message message, PipeLineSession session) DelaySender.sendMessage
(Message message, PipeLineSession session) EchoSender.sendMessage
(Message message, PipeLineSession session) FixedResultSender.sendMessage
(Message message, PipeLineSession session) FrankSender.sendMessage
(Message message, PipeLineSession session) IbisJavaSender.sendMessage
(Message message, PipeLineSession session) IbisLocalSender.sendMessage
(Message message, PipeLineSession session) JavascriptSender.sendMessage
(Message message, PipeLineSession session) LogSender.sendMessage
(Message message, PipeLineSession session) ReloadSender.sendMessage
(Message message, PipeLineSession session) ShadowSender.sendMessage
(Message message, PipeLineSession session) Override this from the parallel sender as it should only execute the original and shadowsenders here!XmlValidatorSender.sendMessage
(Message message, PipeLineSession session) XsltSender.sendMessage
(Message message, PipeLineSession session) alternative implementation of send message, that should do the same as the original, but reuses the streaming content handlerConstructors in org.frankframework.senders with parameters of type PipeLineSessionModifierConstructorDescriptionIsolatedServiceExecutor
(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 PipeLineSessionModifier and TypeMethodDescriptionvoid
SoapWrapper.checkForSoapFault
(Message responseBody, Throwable nested, PipeLineSession session) SoapWrapperPipe.doPipe
(Message message, PipeLineSession session) 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) 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 PipeLineSessionModifier and TypeMethodDescriptionvoid
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 PipeLineSessionModifierConstructorDescriptionThreadConnector
(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 PipeLineSessionModifier and TypeMethodDescriptionstatic 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) -
Uses of PipeLineSession in org.frankframework.validation
Methods in org.frankframework.validation with parameters of type PipeLineSessionModifier and TypeMethodDescriptionXercesXmlValidator.createValidatingParser
(PipeLineSession session, AbstractValidationContext context) 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.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) SchemasProvider.getSchemas
(PipeLineSession session) SchemasProvider.getSchemasId
(PipeLineSession session) abstract ValidatorHandler
AbstractXmlValidator.getValidatorHandler
(PipeLineSession session, AbstractValidationContext context) JavaxXmlValidator.getValidatorHandler
(PipeLineSession session, AbstractValidationContext context) XercesXmlValidator.getValidatorHandler
(PipeLineSession session, AbstractValidationContext context) AbstractXmlValidator.validate
(Message input, PipeLineSession session, ValidatorHandler validatorHandler, XMLFilterImpl filter, AbstractValidationContext context) AbstractXmlValidator.validate
(Message input, PipeLineSession session, RootValidations rootValidations, Map<List<String>, List<String>> invalidRootNamespaces) AbstractXmlValidator.validate
(InputSource inputSource, ValidatorHandler validatorHandler, PipeLineSession session, AbstractValidationContext context) -
Uses of PipeLineSession in org.frankframework.xcom
Methods in org.frankframework.xcom with parameters of type PipeLineSessionModifier and TypeMethodDescriptionXComSender.sendMessage
(Message message, PipeLineSession session) -
Uses of PipeLineSession in org.frankframework.xml
Methods in org.frankframework.xml with parameters of type PipeLineSessionModifier and TypeMethodDescriptionIXmlDebugger.inspectXml
(PipeLineSession session, String label, ContentHandler contentHandler) Allow the debugger to see the XML stream.Constructors in org.frankframework.xml with parameters of type PipeLineSessionModifierConstructorDescriptionRootElementToSessionKeyFilter
(PipeLineSession session, String rootElementSessionKey, String rootNamespaceSessionKey, ContentHandler handler)