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 voidStreamTransformerPipe.closeAllBlocks(PipeLineSession session, String streamId, IResultHandler handler, Map<String, Object> blocks) Deprecated.voidIResultHandler.closeBlock(PipeLineSession session, String streamId, String blockName, Map<String, Object> blocks) voidResultBlock2Sender.closeBlock(PipeLineSession session, String streamId, String blockName, Map<String, Object> blocks) Deprecated.voidResultWriter.closeBlock(PipeLineSession session, String streamId, String blockName, Map<String, Object> blocks) voidAbstractResultHandler.closeDocument(PipeLineSession session, String streamId) voidIResultHandler.closeDocument(PipeLineSession session, String streamId) voidResult2Filewriter.closeDocument(PipeLineSession session, String streamId) Deprecated.voidResultBlock2Sender.closeDocument(PipeLineSession session, String streamId) Deprecated.voidResultWriter.closeDocument(PipeLineSession session, String streamId) voidIResultHandler.closeRecordType(PipeLineSession session, String streamId) voidResultWriter.closeRecordType(PipeLineSession session, String streamId) protected WriterResult2Filewriter.createWriter(PipeLineSession session, String streamId) Deprecated.protected WriterResult2StringWriter.createWriter(PipeLineSession session, String streamId) Deprecated.protected abstract WriterResultWriter.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 InputStreamBatchFileTransformerPipe.getInputStream(String streamId, Message input, PipeLineSession session) Deprecated.protected InputStreamStreamTransformerPipe.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 BufferedReaderStreamTransformerPipe.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 StringBatchFileTransformerPipe.getStreamId(Message input, PipeLineSession session) Deprecated.protected StringStreamTransformerPipe.getStreamId(Message input, PipeLineSession session) Deprecated.protected WriterResultWriter.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.voidIResultHandler.handleResult(PipeLineSession session, String streamId, String recordKey, String result) write a result record.voidResultWriter.handleResult(PipeLineSession session, String streamId, String recordKey, String result) booleanAbstractRecordHandler.isNewRecordType(PipeLineSession session, boolean equalRecordHandlers, List<String> prevRecord, List<String> curRecord) Deprecated.booleanIRecordHandler.isNewRecordType(PipeLineSession session, boolean equalRecordTypes, List<String> prevRecord, List<String> curRecord) voidIResultHandler.openBlock(PipeLineSession session, String streamId, String blockName, Map<String, Object> blocks) voidResultBlock2Sender.openBlock(PipeLineSession session, String streamId, String blockName, Map<String, Object> blocks) Deprecated.voidResultWriter.openBlock(PipeLineSession session, String streamId, String blockName, Map<String, Object> blocks) voidAbstractResultHandler.openDocument(PipeLineSession session, String streamId) voidIResultHandler.openDocument(PipeLineSession session, String streamId) Called once, before the first record of a stream is presented to handleResult.voidResultBlock2Sender.openDocument(PipeLineSession session, String streamId) Deprecated.voidResultWriter.openDocument(PipeLineSession session, String streamId) voidIResultHandler.openRecordType(PipeLineSession session, String streamId) voidResultWriter.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 TypeMethodDescriptionvoidCollection.add(Message input, PipeLineSession session, ParameterValueList pvl) protected voidAbstractCollectorPipe.addPartToCollection(Collection<C, P> collection, Message input, PipeLineSession session, ParameterValueList pvl) protected MessageAbstractCollectorPipe.closeCollector(Collection<C, P> collection, PipeLineSession session) protected abstract CAbstractCollectorPipe.createCollector(Message input, PipeLineSession session) ICollector.createPart(Message input, PipeLineSession session, ParameterValueList pvl) Add a single item to the collectionprotected final MessageAbstractCollectorPipe.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 ParameterValueListAbstractCollectorPipe.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 ZipWriterZipWriterPipe.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 TypeMethodDescriptionvoidIListener.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.voidIBlockEnabledSender.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.IErrorMessageFormatter.format(String errorMessage, Throwable t, HasName location, Message originalMessage, PipeLineSession session) Adapter.formatErrorMessage(String errorMessage, Throwable t, Message originalMessage, PipeLineSession session, HasName objectInError) voidPipeLineSession.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) Theprocessmethod does the processing of a message.
It retrieves the first pipe to execute from thefirstPipefield, 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.voidIMessageHandler.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)TODO Shouldn't this be a IPullingListener or at least an interface that containsIListener.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(IPushingListener<M> origin, MessageWrapper<M> messageWrapper, PipeLineSession session) Alternative to functions above, will NOT useIListener.extractMessage(org.frankframework.receivers.RawMessageWrapper<M>, java.util.Map<java.lang.String, java.lang.Object>)as both input and output are aMessage.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 MessageISender.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.errormessageformatters
Methods in org.frankframework.errormessageformatters with parameters of type PipeLineSessionModifier and TypeMethodDescriptionDataSonnetErrorMessageFormatter.format(String errorMessage, Throwable t, HasName location, Message originalMessage, PipeLineSession session) ErrorMessageFormatter.format(String errorMessage, Throwable t, HasName location, Message originalMessage, PipeLineSession session) Format the available parameters into an XML or JSON message.FixedErrorMessageFormatter.format(String errorMessage, Throwable t, HasName location, Message originalMessage, PipeLineSession session) SoapErrorMessageFormatter.format(String errorMessage, Throwable t, HasName location, Message originalMessage, PipeLineSession session) XslErrorMessageFormatter.format(String errorMessage, Throwable t, HasName location, Message originalMessage, PipeLineSession session) Y01ErrorMessageFormatter.format(String message, Throwable t, HasName location, Message originalMessage, PipeLineSession session) Deprecated. -
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.HttpRequestBaseNetStorageSender.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 StringApiStreamPipe.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.HttpRequestBaseCmisHttpSender.getMethod(URI uri, Message message, ParameterValueList pvl, PipeLineSession session) static voidCmisUtils.populateCmisAttributes(PipeLineSession session) CmisSender.sendMessage(Message message, PipeLineSession session) static org.apache.chemistry.opencmis.commons.data.ObjectDataCmisUtils.xml2ObjectData(Element cmisElement, PipeLineSession context) static org.apache.chemistry.opencmis.commons.data.ObjectListCmisUtils.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 TypeMethodDescriptionvoidEsbJmsListener.afterMessageProcessed(PipeLineResult plr, RawMessageWrapper<jakarta.jms.Message> rawMessageWrapper, PipeLineSession pipeLineSession) DirectWrapperPipe.doPipe(Message message, PipeLineSession session) WsdlGeneratorPipe.doPipe(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 TypeMethodDescriptionvoidFxfListener.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.CommunicatorIdinSender.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 TypeMethodDescriptionvoidKafkaListener.afterMessageProcessed(PipeLineResult processResult, RawMessageWrapper<org.apache.kafka.clients.consumer.ConsumerRecord<String, byte[]>> rawMessage, PipeLineSession pipeLineSession) KafkaSender.sendMessage(Message message, PipeLineSession session) -
Uses of PipeLineSession in org.frankframework.extensions.mqtt
Methods in org.frankframework.extensions.mqtt with parameters of type PipeLineSessionModifier and TypeMethodDescriptionvoidMqttListener.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) RekenBoxCallerPipe.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 TypeMethodDescriptionvoidSapListenerImpl.afterMessageProcessed(PipeLineResult processResult, RawMessageWrapper<M> rawMessageWrapper, PipeLineSession pipeLineSession) static SapLUWHandleSapLUWHandle.createHandle(PipeLineSession session, String sessionKey, SapSystemImpl sapSystem, boolean useTid) SapLUWManagerPipe.doPipe(Message message, PipeLineSession session) com.sap.conn.jco.JCoDestinationSapSenderBase.getDestination(PipeLineSession session, SapSystemImpl sapSystem) static voidSapLUWHandle.releaseHandle(PipeLineSession session, String sessionKey) static SapLUWHandleSapLUWHandle.retrieveHandle(PipeLineSession session, String sessionKey) static SapLUWHandleSapLUWHandle.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 TypeMethodDescriptionvoidAbstractFileSystemListener.afterMessageProcessed(PipeLineResult processResult, RawMessageWrapper<F> rawMessage, PipeLineSession pipeLineSession) FileSystemActor.doAction(Message input, ParameterValueList pvl, PipeLineSession session) AbstractFileSystemPipe.doPipe(Message message, PipeLineSession session) protected MessageMsalClientAdapter.extractResult(HttpResponseHandler responseHandler, PipeLineSession session) protected IDataIterator<A> ForEachAttachmentPipe.getIterator(Message message, PipeLineSession session, Map<String, Object> threadContext) protected org.apache.http.client.methods.HttpRequestBaseMsalClientAdapter.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 TypeMethodDescriptionvoidPushingListenerAdapter.afterMessageProcessed(PipeLineResult processResult, RawMessageWrapper<Message> rawMessage, PipeLineSession pipeLineSession) protected org.apache.http.client.methods.HttpRequestBaseHttpSender.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.HttpResponseAbstractHttpSession.execute(URI targetUri, org.apache.http.client.methods.HttpRequestBase httpRequestBase, PipeLineSession session) By forcing the use of the HttpResponseHandler the resultStream will automatically be closed when it has been read.protected abstract MessageAbstractHttpSender.extractResult(HttpResponseHandler responseHandler, PipeLineSession session) Custom implementation to extract the response and format it to a String result.protected MessageHttpSender.extractResult(HttpResponseHandler responseHandler, PipeLineSession session) protected MessageWebServiceSender.extractResult(HttpResponseHandler responseHandler, PipeLineSession session) protected abstract org.apache.http.client.methods.HttpRequestBaseAbstractHttpSender.getMethod(URI uri, Message message, ParameterValueList parameters, PipeLineSession session) Custom implementation to create aHttpRequestobject.protected org.apache.http.client.methods.HttpRequestBaseHttpSender.getMethod(URI url, Message message, ParameterValueList parameters, PipeLineSession session) protected org.apache.http.client.methods.HttpRequestBaseWebServiceSender.getMethod(URI uri, Message message, ParameterValueList parameters, PipeLineSession session) PushingListenerAdapter.processRequest(Message rawMessage, PipeLineSession session) RestListener.processRequest(Message message, PipeLineSession session) Deprecated, for removal: This API element is subject to removal in a future version.WebServiceListener.processRequest(Message message, PipeLineSession session) static StringRestListenerUtils.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.PushingListenerAdapter.wrapRawMessage(Message rawMessage, PipeLineSession session) -
Uses of PipeLineSession in org.frankframework.http.cxf
Methods in org.frankframework.http.cxf with parameters of type PipeLineSessionModifier and TypeMethodDescriptionprotected MessageNamespaceUriProvider.processRequest(jakarta.xml.soap.SOAPMessage request, PipeLineSession pipelineSession) -
Uses of PipeLineSession in org.frankframework.http.mime
Methods in org.frankframework.http.mime with parameters of type PipeLineSessionModifier and TypeMethodDescriptionorg.apache.http.HttpEntityHttpEntityFactory.create(Message message, ParameterValueList parameters, PipeLineSession session) protected org.apache.http.entity.mime.FormBodyPartHttpEntityFactory.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 TypeMethodDescriptionvoidGraalJS.registerCallback(ISender sender, PipeLineSession session) voidJ2V8.registerCallback(ISender sender, PipeLineSession session) voidJavascriptEngine.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 TypeMethodDescriptionvoidJdbcListener.afterMessageProcessed(PipeLineResult processResult, RawMessageWrapper<M> rawMessage, PipeLineSession pipeLineSession) voidSimpleJdbcListener.afterMessageProcessed(PipeLineResult processResult, RawMessageWrapper<String> rawMessage, PipeLineSession pipeLineSession) voidDirectQuerySender.closeBlock(Connection connection, PipeLineSession session) voidFixedQuerySender.closeBlock(QueryExecutionContext blockHandle, PipeLineSession session) protected voidAbstractJdbcQuerySender.closeConnectionForSendMessage(Connection connection, PipeLineSession session) protected voidDirectQuerySender.closeConnectionForSendMessage(Connection connection, PipeLineSession session) protected WriterResult2LobWriterBase.createWriter(PipeLineSession session, String streamId) protected MessageAbstractJdbcQuerySender.executeOtherQuery(Connection connection, PreparedStatement statement, String query, String resultQuery, PreparedStatement resStmt, Message message, PipeLineSession session, ParameterList parameterList) protected MessageAbstractJdbcQuerySender.executeOtherQuery(QueryExecutionContext queryExecutionContext, Message message, PipeLineSession session) protected MessageStoredProcedureQuerySender.executeOtherQuery(Connection connection, PreparedStatement statement, String query, String resultQuery, PreparedStatement resStmt, Message message, PipeLineSession session, ParameterList parameterList) protected SenderResultAbstractJdbcQuerySender.executeStatementSet(QueryExecutionContext queryExecutionContext, Message message, PipeLineSession session) protected SenderResultResultSet2FileSender.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 ReaderBatchBlobTransformerPipe.getReader(ResultSet rs, String charset, String streamId, PipeLineSession session) Deprecated.protected ReaderBatchClobTransformerPipe.getReader(ResultSet rs, String charset, String streamId, PipeLineSession session) Deprecated.protected BufferedReaderBatchTransformerPipeBase.getReader(String streamId, Message message, PipeLineSession session) Deprecated.protected abstract ReaderBatchTransformerPipeBase.getReader(ResultSet rs, String charset, String streamId, PipeLineSession session) Deprecated.DirectQuerySender.openBlock(PipeLineSession session) FixedQuerySender.openBlock(PipeLineSession session) final SenderResultAbstractJdbcSender.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 TypeMethodDescriptionvoidAbstractJmsListener.afterMessageProcessed(PipeLineResult plr, RawMessageWrapper<jakarta.jms.Message> rawMessageWrapper, PipeLineSession session) voidPullingJmsListener.afterMessageProcessed(PipeLineResult plr, RawMessageWrapper<jakarta.jms.Message> rawMessageWrapper, PipeLineSession pipeLineSession) jakarta.jms.DestinationJmsSender.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 voidAbstractJmsListener.sendReply(PipeLineResult plr, jakarta.jms.Destination replyTo, String replyCid, long timeToLive, boolean ignoreInvalidDestinationException, PipeLineSession pipeLineSession, Map<String, Object> properties) protected voidPullingJmsListener.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 PipeLineSessionPipeLineSessionDebugger.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 pipeLineSession) 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 pipeLineSession) 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 pipeLineSession) IbisDebuggerAdvice.debugPipeLineInputOutputAbort(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint, PipeLine pipeLine, String messageId, Message message, PipeLineSession pipeLineSession) <M> MIbisDebuggerAdvice.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 pipeLineSession) IbisDebuggerAdvice.debugSenderSendMessage(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint, Message message, PipeLineSession pipeLineSession) Provides advice forISender.sendMessage(Message message, PipeLineSession session)IbisDebuggerAdvice.debugSenderSendMessageOrThrow(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint, Message message, PipeLineSession pipeLineSession) Provides advice forISender.sendMessageOrThrow(Message message, PipeLineSession session)IbisDebuggerAdvice.debugValidatorInputOutputAbort(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint, PipeLine pipeLine, IValidator validator, Message message, PipeLineSession pipeLineSession, String messageRoot) LadybugPipe.doPipe(Message message, PipeLineSession session) IbisDebuggerAdvice.getCorrelationId(PipeLineSession session) IbisDebuggerAdvice.inspectXml(PipeLineSession session, String label, ContentHandler contentHandler) static PipeLineSessionPipeLineSessionDebugger.newInstance(PipeLineSession pipeLineSession, LadybugReportGenerator ibisDebugger) -
Uses of PipeLineSession in org.frankframework.larva
Methods in org.frankframework.larva with parameters of type PipeLineSessionModifier and TypeMethodDescriptionvoidListenerMessageHandler.processRawMessage(IListener<M> origin, RawMessageWrapper<M> rawMessage, PipeLineSession threadContext, boolean duplicatesAlreadyChecked) ListenerMessageHandler.processRequest(IPushingListener<M> origin, MessageWrapper<M> rawMessage, 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 PipeRunResultAbstractLdapQueryPipe.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) voidLdapSender.storeLdapException(Throwable t, PipeLineSession session) -
Uses of PipeLineSession in org.frankframework.messaging.amqp
Methods in org.frankframework.messaging.amqp with parameters of type PipeLineSessionModifier and TypeMethodDescriptionvoidAmqpListener.afterMessageProcessed(PipeLineResult processResult, RawMessageWrapper<org.apache.qpid.protonj2.client.Message<?>> rawMessage, PipeLineSession pipeLineSession) AmqpSender.sendMessage(Message message, PipeLineSession session) RawMessageWrapper<org.apache.qpid.protonj2.client.Message<?>> AmqpListener.wrapRawMessage(org.apache.qpid.protonj2.client.Message<?> rawMessage, 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 ParameterValueListParameterValueList.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 StringStreamPipe.adjustFirstStringPart(String firstStringPart, PipeLineSession session) protected PipeRunResultJson2XmlValidator.alignJson(Message messageToValidate, PipeLineSession session, boolean responseMode) protected PipeRunResultJson2XmlValidator.alignXml2Json(Message messageToValidate, PipeLineSession session, boolean responseMode) protected IteratingPipe<I>.ItemCallbackIteratingPipe.createItemCallBack(PipeLineSession session, ISender sender, Writer out) protected IteratingPipe<String>.ItemCallbackStringIteratorPipe.createItemCallBack(PipeLineSession session, ISender sender, Writer writer) protected PipeForwardXmlValidator.determineForward(AbstractXmlValidator.ValidationResult validationResult, PipeLineSession session, boolean responseMode) protected StringAsyncSenderWithListenerPipe.doLogToMessageLog(Message input, PipeLineSession session, Message originalMessage, String messageID, String correlationID) protected StringMessageSendingPipe.doLogToMessageLog(Message input, PipeLineSession session, Message originalMessage, String messageID, String correlationID) final PipeRunResultAbstractValidator.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) GetFromSessionPipe.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.JsonPathPipe.doPipe(Message message, PipeLineSession session) JsonPipe.doPipe(Message message, PipeLineSession session) JsonWellFormedCheckerPipe.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) PutInSessionPipe.doPipe(Message message, PipeLineSession session) PutSystemDateInSession.doPipe(Message message, PipeLineSession session) RegExPipe.doPipe(Message message, PipeLineSession session) RemoveFromSessionPipe.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) SwitchPipe.doPipe(Message message, PipeLineSession session) This is where the action takes place, the switching is done.Text2XmlPipe.doPipe(Message message, PipeLineSession session) TextSplitterPipe.doPipe(Message message, PipeLineSession session) TimeoutGuardPipe.doPipe(Message message, PipeLineSession session) Deprecated.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.XmlValidator.doPipe(Message input, PipeLineSession session, boolean responseMode, String messageRoot) XmlWellFormedCheckerPipe.doPipe(Message message, PipeLineSession session) XQueryPipe.doPipe(Message message, PipeLineSession session) XsltPipe.doPipe(Message input, PipeLineSession session) abstract PipeRunResultTimeoutGuardPipe.doPipeWithTimeoutGuarded(Message input, PipeLineSession session) Deprecated.doPipe wrapped around a TimeoutGuardprotected PipeRunResultXmlValidator.getErrorResult(String reason, PipeLineSession session, boolean responseMode) protected StringIsUserInRolePipe.getFirstMatchingUserRole(PipeLineSession session, List<String> roles) protected InputStreamUnzipPipe.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 ReaderStreamLineIteratorPipe.getReader(Message input, PipeLineSession session, Map<String, Object> threadContext) XmlValidator.getSchemas(PipeLineSession session) XmlValidator.getSchemasId(PipeLineSession session) intMessageSendingPipe.increaseRetryIntervalAndWait(PipeLineSession session, int retryInterval, String description) protected IteratingPipe.StopReasonForEachChildElementPipe.iterateOverInput(Message input, PipeLineSession session, Map<String, Object> threadContext, IteratingPipe<String>.ItemCallback callback) protected IteratingPipe.StopReasonIteratingPipe.iterateOverInput(Message input, PipeLineSession session, Map<String, Object> threadContext, IteratingPipe<I>.ItemCallback callback) protected PipeRunResultAsyncSenderWithListenerPipe.postSendAction(PipeRunResult sendResult, String correlationID, PipeLineSession session) protected PipeRunResultMessageSendingPipe.postSendAction(PipeRunResult sendResult, String correlationID, PipeLineSession session) protected PipeRunResultIteratingPipe.sendMessage(Message input, PipeLineSession session, ISender sender, Map<String, Object> threadContext) protected PipeRunResultMessageSendingPipe.sendMessage(Message input, PipeLineSession session, ISender sender, Map<String, Object> threadContext) protected PipeRunResultMessageSendingPipe.sendMessageWithRetries(Message input, Message originalMessage, PipeLineSession session) booleanFixedForwardPipe.skipPipe(Message input, PipeLineSession session) Called byInputOutputPipeProcessorto check if the pipe needs to be skipped.protected voidJson2XmlValidator.storeInputFormat(DocumentFormat format, Message input, PipeLineSession session, boolean responseMode) protected final PipeForwardAbstractValidator.validate(String messageToValidate, PipeLineSession session) protected abstract PipeForwardAbstractValidator.validate(Message messageToValidate, PipeLineSession session, boolean responseMode, String messageRoot) AbstractValidator.validate(Message message, PipeLineSession session, String messageRoot) protected PipeForwardJsonValidator.validate(Message messageToValidate, PipeLineSession session, boolean responseMode, String messageRoot) protected PipeForwardWsdlXmlValidator.validate(Message messageToValidate, PipeLineSession session, boolean responseMode, String messageRoot) protected PipeForwardXmlValidator.validate(Message messageToValidate, PipeLineSession session, boolean responseMode, String messageRoot) XmlWellFormedCheckerPipe.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 StringCoreListenerProcessor.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 PipeRunResultAbstractPipeProcessor.processPipe(PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession pipeLineSession, ThrowingFunction<Message, PipeRunResult, PipeRunException> chain) protected PipeRunResultCheckMessageSizePipeProcessor.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 PipeRunResultExceptionHandlingPipeProcessor.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 PipeRunResultInputOutputPipeProcessor.processPipe(PipeLine pipeLine, IPipe pipe, Message inputMessage, PipeLineSession pipeLineSession, ThrowingFunction<Message, PipeRunResult, PipeRunException> chain) Processes the pipe in the pipeline.LimitingParallelExecutionPipeProcessor.processPipe(PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession pipeLineSession) protected PipeRunResultLimitingParallelExecutionPipeProcessor.processPipe(PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession pipeLineSession, ThrowingFunction<Message, PipeRunResult, PipeRunException> chain) protected PipeRunResultLockerPipeProcessor.processPipe(PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession pipeLineSession, ThrowingFunction<Message, PipeRunResult, PipeRunException> chain) protected PipeRunResultLogPipeProcessor.processPipe(PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession pipeLineSession, ThrowingFunction<Message, PipeRunResult, PipeRunException> chain) protected PipeRunResultMonitoringPipeProcessor.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 PipeRunResultTrackPreviousPipeInMetadataProcessor.processPipe(PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession pipeLineSession, ThrowingFunction<Message, PipeRunResult, PipeRunException> chain) protected PipeRunResultTransactionAttributePipeProcessor.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 TypeMethodDescriptionvoidFrankListener.afterMessageProcessed(PipeLineResult processResult, RawMessageWrapper<Message> rawMessage, PipeLineSession pipeLineSession) voidJavaListener.afterMessageProcessed(PipeLineResult processResult, RawMessageWrapper<M> rawMessage, PipeLineSession pipeLineSession) ServiceDispatcher.dispatchRequest(String serviceName, Message message, PipeLineSession session) Dispatch a requestMessageto a service by its configured name.protected booleanReceiver.isDeliveryRetryLimitExceededBeforeMessageProcessing(RawMessageWrapper<M> rawMessageWrapper, PipeLineSession session, boolean manualRetry) returns true if message should not be processed when it is delivered.voidReceiver.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.voidReceiver.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(IPushingListener<M> origin, MessageWrapper<M> messageWrapper, PipeLineSession session) Process the received message withIMessageHandler.processRequest(IPushingListener, MessageWrapper, 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 TypeMethodDescriptionvoidIsolatedServiceCaller.callServiceAsynchronous(ServiceClient service, Message message, PipeLineSession session, ThreadLifeCycleEventListener<?> threadLifeCycleEventListener) IsolatedServiceCaller.callServiceIsolated(ServiceClient service, Message message, PipeLineSession session, ThreadLifeCycleEventListener<?> threadLifeCycleEventListener) protected ContentHandlerJsonXsltSender.createHandler(Message input, PipeLineSession session, TransformerPool poolToUse, ContentHandler handler, MessageBuilder messageBuilder) protected ContentHandlerXsltSender.createHandler(Message input, PipeLineSession session, TransformerPool poolToUse, ContentHandler handler, MessageBuilder messageBuilder) abstract SenderResultAbstractSenderWrapper.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 voidShadowSender.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 ContentHandlerXsltSender.filterInput(ContentHandler input, PipeLineSession session) protected ParameterValueListAbstractSenderWithParameters.getParameterValueList(Message input, PipeLineSession session) protected TransformerPoolXsltSender.getTransformerPoolToUse(PipeLineSession session) protected XMLReaderJsonXsltSender.getXmlReader(PipeLineSession session, ContentHandler handler) protected XMLReaderXsltSender.getXmlReader(PipeLineSession session, ContentHandler handler) final SenderResultAbstractBlockEnabledSender.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 TypeMethodDescriptionvoidSoapWrapper.checkForSoapFault(Message responseBody, Throwable nested, PipeLineSession session) SoapWrapperPipe.doPipe(Message message, PipeLineSession session) SoapWrapper.getBody(Message message, boolean allowPlainXml, PipeLineSession session, String soapNamespaceSessionKey) protected StringSoapWrapper.getFaultCode(Message message, PipeLineSession session) protected StringSoapWrapper.getFaultString(Message message, PipeLineSession session) SoapWrapper.getHeader(Message message, PipeLineSession session) protected MessageSoapWrapperPipe.unwrapMessage(Message message, PipeLineSession session) protected MessageSoapWrapperPipe.wrapMessage(Message message, String soapHeader, 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 voidJdbcUtil.applyParameters(IDbmsSupport dbmsSupport, PreparedStatement statement, ParameterList parameters, Message message, PipeLineSession session) static voidJdbcUtil.applyParameters(IDbmsSupport dbmsSupport, PreparedStatement statement, ParameterValueList parameters, PipeLineSession session) static StringFileUtils.getFilename(ParameterList definedParameters, PipeLineSession session, File originalFile, String filenamePattern) static org.apache.logging.log4j.CloseableThreadContext.InstanceLogUtil.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.JavaxValidationContextJavaxXmlValidator.createValidationContext(PipeLineSession session, RootValidations rootValidations, Map<List<String>, List<String>> invalidRootNamespaces) org.frankframework.validation.XercesValidationContextXercesXmlValidator.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 StringAbstractXmlValidator.getLogPrefix(PipeLineSession session) protected org.frankframework.validation.PreparseResultXercesXmlValidator.getPreparseResult(PipeLineSession session) SchemasProvider.getSchemas(PipeLineSession session) SchemasProvider.getSchemasId(PipeLineSession session) abstract ValidatorHandlerAbstractXmlValidator.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)