Uses of Class
org.frankframework.stream.Message
Package
Description
-
Uses of Message in org.frankframework.cache
Modifier and TypeMethodDescriptionRemoveCacheKeyPipe.doPipe
(Message message, PipeLineSession session) protected abstract V
protected V
CacheAdapterBase.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 Message in org.frankframework.collection
Modifier and TypeMethodDescriptionCollection.build()
closes the collector'builds' the collection and returns a persistent Messageprotected Message
CollectorPipeBase.closeCollector
(Collection<C, P> collection, PipeLineSession session) protected final Message
CollectorPipeBase.doAction
(CollectorPipeBase.Action action, Message input, PipeLineSession session) Modifier and TypeMethodDescriptionvoid
Collection.add
(Message input, PipeLineSession session, ParameterValueList pvl) protected void
CollectorPipeBase.addPartToCollection
(Collection<C, P> collection, Message input, PipeLineSession session, ParameterValueList pvl) protected abstract C
CollectorPipeBase.createCollector
(Message input, PipeLineSession session) ICollector.createPart
(Message input, PipeLineSession session, ParameterValueList pvl) Add a single item to the collectionprotected final Message
CollectorPipeBase.doAction
(CollectorPipeBase.Action action, Message input, PipeLineSession session) CollectorPipeBase.doPipe
(Message input, PipeLineSession session) protected ParameterValueList
CollectorPipeBase.getParameterValueList
(Message input, PipeLineSession session) CollectorSenderBase.sendMessage
(Message message, PipeLineSession session) -
Uses of Message in org.frankframework.compression
Modifier 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) protected ZipInputStream
ZipIteratorPipe.getZipInputStream
(Message input, PipeLineSession session, Map<String, Object> threadContext) ZipWriterSender.sendMessage
(Message message, PipeLineSession session) ModifierConstructorDescriptionMessageZipEntry
(Message message) MessageZipEntry
(Message message, String filename) -
Uses of Message in org.frankframework.core
Modifier and TypeMethodDescriptionIListener.extractMessage
(RawMessageWrapper<M> rawMessage, Map<String, Object> context) Extracts data from message obtained fromIPullingListener.getRawMessage(Map)
orIPushingListener.wrapRawMessage(Object, PipeLineSession)
.IErrorMessageFormatter.format
(String errorMessage, Throwable t, INamedObject location, Message originalMessage, String messageId, long receivedTime) Adapter.formatErrorMessage
(String errorMessage, Throwable t, Message originalMessage, String messageID, INamedObject objectInError, long receivedTime) IAdapter.formatErrorMessage
(String errorMessage, Throwable t, Message originalMessage, String messageID, INamedObject objectInError, long receivedTime) IMessageHandler.formatException
(String extraInfo, String correlationId, Message message, Throwable t) Formats any exception thrown by any of the above methods to a message that can be returned.PipeLineSession.getMessage
(String key) Retrieves the value associated with the specified key and returns it as aMessage
object.RequestReplyExecutor.getRequest()
PipeLineResult.getResult()
PipeRunResult.getResult()
SenderResult.getResult()
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>)
.default Message
ISender.sendMessageOrThrow
(Message message, PipeLineSession session) Modifier and TypeMethodDescriptionIPipe.doPipe
(Message message, PipeLineSession session) This is where the action takes place.IErrorMessageFormatter.format
(String errorMessage, Throwable t, INamedObject location, Message originalMessage, String messageId, long receivedTime) Adapter.formatErrorMessage
(String errorMessage, Throwable t, Message originalMessage, String messageID, INamedObject objectInError, long receivedTime) IAdapter.formatErrorMessage
(String errorMessage, Throwable t, Message originalMessage, String messageID, INamedObject objectInError, long receivedTime) IMessageHandler.formatException
(String extraInfo, String correlationId, Message message, Throwable t) Formats any exception thrown by any of the above methods to a message that can be returned.void
Adapter.logToMessageLogWithMessageContentsOrSize
(org.apache.logging.log4j.Level level, String logMessage, String dataPrefix, Message data) 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</code field, the call results in a PipRunResult, containing the next pipe to activate.
Adapter.processMessage
(String messageId, Message message, PipeLineSession pipeLineSession) IAdapter.processMessage
(String messageId, Message message, PipeLineSession pipeLineSession) Adapter.processMessageWithExceptions
(String messageId, Message message, PipeLineSession pipeLineSession) IAdapter.processMessageWithExceptions
(String messageId, Message message, PipeLineSession 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) void
RequestReplyExecutor.setRequest
(Message request) void
void
void
IPipe.throwEvent
(String event, Message eventMessage) IValidator.validate
(Message message, PipeLineSession session, String messageRoot) ModifierConstructorDescriptionSenderResult
(boolean success, Message result, String errorMessage, String forwardName) SenderResult
(Message result) SenderResult
(Message result, String errorMessage) -
Uses of Message in org.frankframework.errormessageformatters
Modifier and TypeMethodDescriptionErrorMessageFormatter.format
(String errorMessage, Throwable t, INamedObject location, Message originalMessage, String messageId, long receivedTime) Format the available parameters into a XML-message.FixedErrorMessageFormatter.format
(String errorMessage, Throwable t, INamedObject location, Message originalMessage, String messageId, long receivedTime) SoapErrorMessageFormatter.format
(String errorMessage, Throwable t, INamedObject location, Message originalMessage, String messageId, long receivedTime) XslErrorMessageFormatter.format
(String errorMessage, Throwable t, INamedObject location, Message originalMessage, String messageId, long receivedTime) Modifier and TypeMethodDescriptionErrorMessageFormatter.format
(String errorMessage, Throwable t, INamedObject location, Message originalMessage, String messageId, long receivedTime) Format the available parameters into a XML-message.FixedErrorMessageFormatter.format
(String errorMessage, Throwable t, INamedObject location, Message originalMessage, String messageId, long receivedTime) SoapErrorMessageFormatter.format
(String errorMessage, Throwable t, INamedObject location, Message originalMessage, String messageId, long receivedTime) XslErrorMessageFormatter.format
(String errorMessage, Throwable t, INamedObject location, Message originalMessage, String messageId, long receivedTime) -
Uses of Message in org.frankframework.http
Modifier and TypeMethodDescriptionRestServiceDispatcher.dispatchRequest
(String restPath, String uri, jakarta.servlet.http.HttpServletRequest httpServletRequest, String contentType, String request, PipeLineSession context, jakarta.servlet.http.HttpServletResponse httpServletResponse, jakarta.servlet.ServletContext servletContext) Dispatch a request.PushingListenerAdapter.extractMessage
(RawMessageWrapper<Message> rawMessage, Map<String, Object> context) protected Message
HttpSender.extractResult
(HttpResponseHandler responseHandler, PipeLineSession session) protected abstract Message
HttpSenderBase.extractResult
(HttpResponseHandler responseHandler, PipeLineSession session) Custom implementation to extract the response and format it to a String result.protected Message
RestSender.extractResult
(HttpResponseHandler responseHandler, PipeLineSession session) Deprecated.protected Message
WebServiceSender.extractResult
(HttpResponseHandler responseHandler, PipeLineSession session) HttpSender.getResponseBody
(HttpResponseHandler responseHandler) HttpResponseHandler.getResponseMessage()
static Message
HttpSender.handleMultipartResponse
(String mimeType, InputStream inputStream, PipeLineSession session) return the first part as Message and put the other parts as InputStream in the PipeLineSessionPushingListenerAdapter.processRequest
(Message rawMessage, PipeLineSession session) RestListener.processRequest
(Message message, PipeLineSession session) WebServiceListener.processRequest
(Message message, PipeLineSession session) RestListener.transformToJson
(Message message) RestListener.transformToXml
(Message message) Modifier and TypeMethodDescriptionPushingListenerAdapter.wrapRawMessage
(Message rawMessage, PipeLineSession session) Modifier and TypeMethodDescriptionprotected org.apache.http.client.methods.HttpRequestBase
HttpSender.getMethod
(URI uri, Message message, ParameterValueList parameters) Returns HttpRequestBase, with (optional) RAW or as BINAIRY contentprotected org.apache.http.client.methods.HttpRequestBase
HttpSender.getMethod
(URI url, Message message, ParameterValueList parameters, PipeLineSession session) protected abstract org.apache.http.client.methods.HttpRequestBase
HttpSenderBase.getMethod
(URI uri, Message message, ParameterValueList parameters, PipeLineSession session) Custom implementation to create aHttpRequest
object.protected org.apache.http.client.methods.HttpRequestBase
WebServiceSender.getMethod
(URI uri, Message message, ParameterValueList parameters, PipeLineSession session) void
HttpListenerServlet.invoke
(Message message, jakarta.servlet.http.HttpServletRequest request, jakarta.servlet.http.HttpServletResponse response) PushingListenerAdapter.processRequest
(Message rawMessage, PipeLineSession session) RestListener.processRequest
(Message message, PipeLineSession session) WebServiceListener.processRequest
(Message message, PipeLineSession session) HttpSenderBase.sendMessage
(Message message, PipeLineSession session) RestListener.transformToJson
(Message message) RestListener.transformToXml
(Message message) PushingListenerAdapter.wrapRawMessage
(Message rawMessage, PipeLineSession session) Modifier and TypeMethodDescriptionvoid
PushingListenerAdapter.afterMessageProcessed
(PipeLineResult processResult, RawMessageWrapper<Message> rawMessage, PipeLineSession pipeLineSession) PushingListenerAdapter.extractMessage
(RawMessageWrapper<Message> rawMessage, Map<String, Object> context) void
PushingListenerAdapter.setHandler
(IMessageHandler<Message> handler) ModifierConstructorDescriptionHttpMessageEntity
(Message message) HttpMessageEntity
(Message message, org.apache.http.entity.ContentType contentType) -
Uses of Message in org.frankframework.http.mime
Modifier and TypeMethodDescriptionvoid
ModifierConstructorDescriptionMessageContentBody
(Message message) MessageContentBody
(Message message, org.springframework.util.MimeType contentType) MessageContentBody
(Message message, org.springframework.util.MimeType contentType, String filename) -
Uses of Message in org.frankframework.http.rest
Modifier and TypeMethodDescriptionApiPrincipalPipe.doPipe
(Message message, PipeLineSession session) -
Uses of Message in org.frankframework.jdbc
Modifier and TypeMethodDescriptionprotected Message
JdbcQuerySenderBase.executeOtherQuery
(Connection connection, PreparedStatement statement, String query, String resultQuery, PreparedStatement resStmt, Message message, PipeLineSession session, ParameterList parameterList) protected Message
JdbcQuerySenderBase.executeOtherQuery
(QueryExecutionContext queryExecutionContext, Message message, PipeLineSession session) protected Message
StoredProcedureQuerySender.executeOtherQuery
(Connection connection, PreparedStatement statement, String query, String resultQuery, PreparedStatement resStmt, Message message, PipeLineSession session, ParameterList parameterList) protected Message
JdbcQuerySenderBase.executePackageQuery
(QueryExecutionContext queryExecutionContext) protected Message
JdbcQuerySenderBase.executeUpdateBlobQuery
(PreparedStatement statement, Message contents) protected Message
JdbcQuerySenderBase.executeUpdateClobQuery
(PreparedStatement statement, Message contents) JdbcListener.extractMessage
(RawMessageWrapper<M> rawMessage, Map<String, Object> context) MessageStoreListener.extractMessage
(RawMessageWrapper<M> rawMessage, Map<String, Object> context) SimpleJdbcListener.extractMessage
(RawMessageWrapper<String> rawMessage, Map<String, Object> context) protected Message
protected Message
protected Message
JdbcQuerySenderBase.getUpdateStatementResult
(PreparedStatement statement, String resultQuery, PreparedStatement resStmt, int numRowsAffected) Modifier and TypeMethodDescriptionprotected Message
JdbcQuerySenderBase.executeOtherQuery
(Connection connection, PreparedStatement statement, String query, String resultQuery, PreparedStatement resStmt, Message message, PipeLineSession session, ParameterList parameterList) protected Message
JdbcQuerySenderBase.executeOtherQuery
(QueryExecutionContext queryExecutionContext, Message message, PipeLineSession session) protected Message
StoredProcedureQuerySender.executeOtherQuery
(Connection connection, PreparedStatement statement, String query, String resultQuery, PreparedStatement resStmt, Message message, PipeLineSession session, ParameterList parameterList) protected PipeRunResult
JdbcQuerySenderBase.executeStatementSet
(QueryExecutionContext queryExecutionContext, Message message, PipeLineSession session, IForwardTarget next) protected PipeRunResult
ResultSet2FileSender.executeStatementSet
(QueryExecutionContext queryExecutionContext, Message message, PipeLineSession session, IForwardTarget next) protected Message
JdbcQuerySenderBase.executeUpdateBlobQuery
(PreparedStatement statement, Message contents) protected Message
JdbcQuerySenderBase.executeUpdateClobQuery
(PreparedStatement statement, Message contents) protected IDataIterator<String>
JdbcIteratingPipeBase.getIterator
(Message message, PipeLineSession session, Map<String, Object> threadContext) protected String
protected String
protected String
protected abstract String
Obtain a query to be executed.JdbcQuerySenderBase.getQueryExecutionContext
(Connection connection, Message message) protected QueryExecutionContext
DirectQuerySender.prepareStatementSet
(Connection connection, Message message) DirectQuerySender.sendMessage
(Connection blockHandle, Message message, PipeLineSession session) FixedQuerySender.sendMessage
(QueryExecutionContext blockHandle, Message message, PipeLineSession session) final SenderResult
JdbcSenderBase.sendMessage
(Message message, PipeLineSession session) MessageStoreSender.sendMessage
(Message message, PipeLineSession session) protected PipeRunResult
DirectQuerySender.sendMessageOnConnection
(Connection connection, Message message, PipeLineSession session, IForwardTarget next) protected PipeRunResult
XmlQuerySender.sendMessageOnConnection
(Connection connection, Message message, PipeLineSession session, IForwardTarget next) -
Uses of Message in org.frankframework.jdbc.transformer
-
Uses of Message in org.frankframework.jms
Modifier and TypeMethodDescriptionJMSFacade.extractMessage
(jakarta.jms.Message jmsMessage, Map<String, Object> context, boolean soap, String soapHeaderSessionKey, SoapWrapper soapWrapper) Extracts string from message obtained from getRawMessage(Map).JmsListenerBase.extractMessage
(RawMessageWrapper<jakarta.jms.Message> rawMessage, Map<String, Object> context) Extracts data from message obtained fromIPullingListener.getRawMessage(Map)
.protected Message
JMSFacade.extractMessageBody
(Message message, Map<String, Object> context, SoapWrapper soapWrapper) JmsListenerBase.prepareReply
(Message rawReply, Map<String, Object> threadContext) JmsSender.sendMessage
(Message message, PipeLineSession pipeLineSession, String soapHeader) Modifier and TypeMethodDescriptionprotected jakarta.jms.Message
JMSFacade.createBytesMessage
(jakarta.jms.Session session, String correlationID, Message message) jakarta.jms.Message
JMSFacade.createMessage
(jakarta.jms.Session session, String correlationID, Message message) jakarta.jms.Message
JMSFacade.createMessage
(jakarta.jms.Session session, String correlationID, Message message, JMSFacade.MessageClass messageClass) protected jakarta.jms.TextMessage
JMSFacade.createTextMessage
(jakarta.jms.Session session, String correlationID, Message message) protected Message
JMSFacade.extractMessageBody
(Message message, Map<String, Object> context, SoapWrapper soapWrapper) JmsListenerBase.prepareReply
(Message rawReply, Map<String, Object> threadContext) JMSFacade.send
(jakarta.jms.Session session, jakarta.jms.Destination dest, String correlationId, Message message, String messageType, long timeToLive, int deliveryMode, int priority) JMSFacade.send
(jakarta.jms.Session session, jakarta.jms.Destination dest, String correlationId, Message message, String messageType, long timeToLive, int deliveryMode, int priority, boolean ignoreInvalidDestinationException) JMSFacade.send
(jakarta.jms.Session session, jakarta.jms.Destination dest, String correlationId, Message message, String messageType, long timeToLive, int deliveryMode, int priority, boolean ignoreInvalidDestinationException, Map<String, Object> properties) JmsSender.sendMessage
(Message message, PipeLineSession session) JmsSender.sendMessage
(Message message, PipeLineSession pipeLineSession, String soapHeader) XmlJmsBrowserSender.sendMessage
(Message message, PipeLineSession session) -
Uses of Message in org.frankframework.ldap
Modifier and TypeMethodDescriptionLdapChallengePipe.doPipe
(Message msg, PipeLineSession pls) Deprecated.Checks to see if the supplied parameteres of the pipe can login to LDAPLdapQueryPipeBase.doPipe
(Message message, PipeLineSession session) LdapFindGroupMembershipsPipe.doPipeWithException
(Message message, PipeLineSession session) LdapFindMemberPipe.doPipeWithException
(Message message, PipeLineSession session) abstract PipeRunResult
LdapQueryPipeBase.doPipeWithException
(Message message, PipeLineSession session) LdapSender.performOperation
(Message message, PipeLineSession session) Performs the specified operation and returns the results.LdapSender.sendMessage
(Message message, PipeLineSession session) -
Uses of Message in org.frankframework.mongodb
Modifier and TypeMethodDescriptionprotected org.bson.Document
MongoDbSender.getDocument
(Message message) protected List<org.bson.Document>
MongoDbSender.getDocuments
(Message message) protected org.bson.Document
MongoDbSender.getFilter
(ParameterValueList pvl, Message message) MongoDbSender.sendMessage
(Message message, PipeLineSession session) -
Uses of Message in org.frankframework.monitoring
Modifier and TypeMethodDescriptionvoid
EventPublisher.fireEvent
(EventThrowing source, String eventCode, Message eventMessage) -
Uses of Message in org.frankframework.monitoring.events
ModifierConstructorDescriptionFireMonitorEvent
(EventThrowing source, String eventCode, Message eventMessage) MonitorEvent
(EventThrowing source, String eventCode, Message eventMessage) -
Uses of Message in org.frankframework.parameters
Modifier and TypeMethodDescriptionParameterValue.asMessage()
static Message
ParameterValueList.getValue
(ParameterValueList pvl, String name, Message defaultValue) Modifier and TypeMethodDescriptionvoid
ParameterList.addMatchingSessionKeys
(ParameterValueList result, Parameter parm, Message message, PipeLineSession session, boolean namespaceAware) static ParameterValueList
ParameterValueList.get
(ParameterList params, Message message, PipeLineSession session) Parameter.getValue
(ParameterValueList alreadyResolvedParameters, Message message, PipeLineSession session, boolean namespaceAware) determines the raw valueParameterList.getValue
(ParameterValueList alreadyResolvedParameters, Parameter p, Message message, PipeLineSession session, boolean namespaceAware) static Message
ParameterValueList.getValue
(ParameterValueList pvl, String name, Message defaultValue) ParameterList.getValues
(Message message, PipeLineSession session) ParameterList.getValues
(Message message, PipeLineSession session, boolean namespaceAware) Returns a List of ParameterValue objects -
Uses of Message in org.frankframework.pipes
Modifier and TypeMethodDescriptionprotected void
ForEachChildElementPipe.createHandler
(org.frankframework.pipes.ForEachChildElementPipe.HandlerRecord result, ThreadConnector<?> threadConnector, Message input, PipeLineSession session, IteratingPipe<String>.ItemCallback callback) Base64Pipe.doPipe
(Message message, PipeLineSession session) BytesOutputPipe.doPipe
(Message message, PipeLineSession session) ChecksumPipe.doPipe
(Message message, PipeLineSession session) 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) 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) FileLineIteratorPipe.doPipe
(Message input, PipeLineSession session) Deprecated.Open a reader for the file named according the input messsage and transform it.FilenameSwitch.doPipe
(Message message, PipeLineSession session) Deprecated.FixedResultPipe.doPipe
(Message message, PipeLineSession session) GetFromSession.doPipe
(Message message, PipeLineSession session) GetPrincipalPipe.doPipe
(Message message, PipeLineSession session) HashPipe.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) 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) PostboxRetrieverPipe.doPipe
(Message message, PipeLineSession session) Deprecated.PutInSession.doPipe
(Message message, PipeLineSession session) PutParametersInSession.doPipe
(Message message, PipeLineSession session) Deprecated.PutSystemDateInSession.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) Stream2StringPipe.doPipe
(Message message, PipeLineSession session) Deprecated.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) final PipeRunResult
ValidatorBase.doPipe
(Message message, PipeLineSession session) ValidatorBase.doPipe
(Message input, PipeLineSession session, boolean responseMode, String messageRoot) ValidatorBase.ResponseValidatorWrapper.doPipe
(Message message, PipeLineSession session) WsdlGeneratorPipe.doPipe
(Message message, PipeLineSession session) XmlBuilderPipe.doPipe
(Message message, PipeLineSession session) Deprecated.XmlIf.doPipe
(Message message, PipeLineSession session) 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) XmlValidator.ResponseValidatorWrapper.doPipe
(Message message, PipeLineSession session) 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 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) protected Reader
StreamLineIteratorPipe.getReader
(Message input, PipeLineSession session, Map<String, Object> threadContext) IsUserInRolePipe.getRolesToCheck
(Message message) protected IteratingPipe.StopReason
ForEachChildElementPipe.iterateOverInput
(Message input, PipeLineSession session, Map<String, Object> threadContext, IteratingPipe<String>.ItemCallback callback) protected IteratingPipe.StopReason
IteratingPipe.iterateOverInput
(Message input, PipeLineSession session, Map<String, Object> threadContext, IteratingPipe<I>.ItemCallback callback) protected IteratingPipe.StopReason
XmlFileElementIteratorPipe.iterateOverInput
(Message input, PipeLineSession session, Map<String, Object> threadContext, IteratingPipe<String>.ItemCallback callback) Deprecated.protected void
Callpreserve()
so it can be consumed multiple times, and wrap potentialIOException
in aPipeRunException
.protected PipeRunResult
IteratingPipe.sendMessage
(Message input, PipeLineSession session, ISender sender, Map<String, Object> threadContext) protected PipeRunResult
MessageSendingPipe.sendMessage
(Message input, PipeLineSession session, ISender sender, Map<String, Object> threadContext) boolean
FixedForwardPipe.skipPipe
(Message input, PipeLineSession session) called byInputOutputPipeProcessor
to check if the pipe needs to be skipped.protected void
Json2XmlValidator.storeInputFormat
(DocumentFormat format, Message input, PipeLineSession session, boolean responseMode) void
AbstractPipe.throwEvent
(String event, Message message) void
ValidatorBase.ResponseValidatorWrapper.throwEvent
(String event, Message eventMessage) void
XmlValidator.ResponseValidatorWrapper.throwEvent
(String event, Message eventMessage) protected PipeForward
JsonValidator.validate
(Message messageToValidate, PipeLineSession session, boolean responseMode, String messageRoot) ValidatorBase.ResponseValidatorWrapper.validate
(Message message, PipeLineSession session, String messageRoot) protected abstract PipeForward
ValidatorBase.validate
(Message messageToValidate, PipeLineSession session, boolean responseMode, String messageRoot) ValidatorBase.validate
(Message message, PipeLineSession session, String messageRoot) protected PipeForward
WsdlXmlValidator.validate
(Message messageToValidate, PipeLineSession session, boolean responseMode, String messageRoot) XmlValidator.ResponseValidatorWrapper.validate
(Message message, PipeLineSession session, String messageRoot) protected PipeForward
XmlValidator.validate
(Message messageToValidate, PipeLineSession session, boolean responseMode, String messageRoot) XmlWellFormedChecker.validate
(Message message, PipeLineSession session, String messageRoot) -
Uses of Message in org.frankframework.processors
Modifier and TypeMethodDescriptionCoreListenerProcessor.getMessage
(ICorrelatedPullingListener<M> listener, String correlationID, PipeLineSession pipeLineSession) ListenerProcessor.getMessage
(ICorrelatedPullingListener<M> listener, String correlationID, PipeLineSession pipeLineSession) Modifier and TypeMethodDescriptionprotected 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) PipeProcessorBase.processPipe
(PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession pipeLineSession) protected abstract PipeRunResult
PipeProcessorBase.processPipe
(PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession pipeLineSession, ThrowingFunction<Message, PipeRunResult, PipeRunException> chain) protected PipeRunResult
TransactionAttributePipeProcessor.processPipe
(PipeLine pipeline, IPipe pipe, Message message, PipeLineSession pipeLineSession, ThrowingFunction<Message, PipeRunResult, PipeRunException> chain) 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
(SenderWrapperBase senderWrapperBase, Message message, PipeLineSession session) CoreSenderWrapperProcessor.sendMessage
(SenderWrapperBase senderWrapperBase, Message message, PipeLineSession session) InputOutputSenderWrapperProcessor.sendMessage
(SenderWrapperBase senderWrapperBase, Message message, PipeLineSession session) SenderWrapperProcessor.sendMessage
(SenderWrapperBase senderWrapperBase, Message message, PipeLineSession session) 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) PipeProcessorBase.validate
(PipeLine pipeLine, IValidator validator, Message message, PipeLineSession pipeLineSession, String messageRoot) Modifier and TypeMethodDescriptionprotected PipeRunResult
CheckMessageSizePipeProcessor.processPipe
(PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession pipeLineSession, ThrowingFunction<Message, PipeRunResult, PipeRunException> chain) protected PipeRunResult
ExceptionHandlingPipeProcessor.processPipe
(PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession pipeLineSession, ThrowingFunction<Message, PipeRunResult, PipeRunException> chain) protected PipeRunResult
InputOutputPipeProcessor.processPipe
(PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession pipeLineSession, ThrowingFunction<Message, PipeRunResult, PipeRunException> chain) Processes the pipe in the pipeline.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) protected abstract PipeRunResult
PipeProcessorBase.processPipe
(PipeLine pipeLine, IPipe pipe, Message message, PipeLineSession pipeLineSession, ThrowingFunction<Message, PipeRunResult, PipeRunException> chain) protected PipeRunResult
TransactionAttributePipeProcessor.processPipe
(PipeLine pipeline, IPipe pipe, Message message, PipeLineSession pipeLineSession, ThrowingFunction<Message, PipeRunResult, PipeRunException> chain) -
Uses of Message in org.frankframework.receivers
Modifier and TypeMethodDescriptionServiceDispatcher.dispatchRequest
(String serviceName, Message message, PipeLineSession session) Dispatch a requestMessage
to a service by its configured name.FileRecordListener.extractMessage
(RawMessageWrapper<String> rawMessage, Map<String, Object> context) Deprecated.JavaListener.extractMessage
(RawMessageWrapper<M> rawMessage, Map<String, Object> context) Receiver.formatException
(String extraInfo, String messageId, Message message, Throwable t) MessageWrapper.getMessage()
JavaListener.processRequest
(Message message, PipeLineSession session) Receiver.processRequest
(IListener<M> origin, RawMessageWrapper<M> rawMessage, Message message, PipeLineSession session) Process the received message withReceiver.processRequest(IListener, RawMessageWrapper, Message, PipeLineSession)
.ServiceClient.processRequest
(Message message, PipeLineSession session) Method to implement for processing a request.Modifier and TypeMethodDescriptionServiceDispatcher.dispatchRequest
(String serviceName, Message message, PipeLineSession session) Dispatch a requestMessage
to a service by its configured name.Receiver.formatException
(String extraInfo, String messageId, Message message, Throwable t) JavaListener.processRequest
(Message message, PipeLineSession session) Receiver.processRequest
(IListener<M> origin, RawMessageWrapper<M> rawMessage, Message message, PipeLineSession session) Process the received message withReceiver.processRequest(IListener, RawMessageWrapper, Message, PipeLineSession)
.ServiceClient.processRequest
(Message message, PipeLineSession session) Method to implement for processing a request.ModifierConstructorDescriptionMessageWrapper
(RawMessageWrapper<M> rawMessageWrapper, Message message) MessageWrapper
(RawMessageWrapper<M> rawMessageWrapper, Message message, String messageId, String correlationId) MessageWrapper
(Message message, String messageId, String correlationId) -
Uses of Message in org.frankframework.scheduler
Modifier and TypeMethodDescriptionSchedulerSender.sendMessage
(Message message, PipeLineSession session) -
Uses of Message in org.frankframework.senders
Modifier 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, ThreadConnector threadConnector, PipeLineSession session, TransformerPool poolToUse, ContentHandler handler, File tempFile) protected ContentHandler
XsltSender.createHandler
(Message input, ThreadConnector threadConnector, PipeLineSession session, TransformerPool poolToUse, ContentHandler handler, File tempFile) ParallelSenders.doSendMessage
(Message message, PipeLineSession session) ReconnectSenderWrapper.doSendMessage
(Message message, PipeLineSession session) SenderSeries.doSendMessage
(Message message, PipeLineSession session) SenderWrapper.doSendMessage
(Message message, PipeLineSession session) abstract SenderResult
SenderWrapperBase.doSendMessage
(Message message, PipeLineSession session) protected void
ShadowSender.executeGuarded
(ISender sender, Message message, PipeLineSession session, Phaser guard, Map<ISender, ParallelSenderExecutor> executorMap) MailSenderBase.extract
(Message input, PipeLineSession session) Reads fields from either paramList or Xml fileprotected ParameterValueList
SenderWithParametersBase.getParameterValueList
(Message input, PipeLineSession session) final SenderResult
BlockEnabledSenderBase.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) IbisJavaSender.sendMessage
(Message message, PipeLineSession session) IbisLocalSender.sendMessage
(Message message, PipeLineSession session) JavascriptSender.sendMessage
(Message message, PipeLineSession session) LogSender.sendMessage
(Message message, PipeLineSession session) MailSenderBase.sendMessage
(Message message, PipeLineSession session) ReloadSender.sendMessage
(Message message, PipeLineSession session) SenderWrapperBase.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 handlerModifierConstructorDescriptionIsolatedServiceExecutor
(ServiceClient service, Message message, PipeLineSession session, CountDownLatch guard, ThreadLifeCycleEventListener<?> threadLifeCycleEventListener) ParallelSenderExecutor
(ISender sender, Message message, PipeLineSession session, io.micrometer.core.instrument.DistributionSummary summary) -
Uses of Message in org.frankframework.soap
Modifier and TypeMethodDescriptionSoapWrapper.createSoapFaultMessage
(String faultstring) SoapWrapper.createSoapFaultMessage
(String faultcode, String faultstring) SoapWrapper.getBody
(Message message, boolean allowPlainXml, PipeLineSession session, String soapNamespaceSessionKey) SoapWrapper.putInEnvelope
(Message message, String encodingStyleUri) SoapWrapper.putInEnvelope
(Message message, String encodingStyleUri, String targetObjectNamespace) SoapWrapper.putInEnvelope
(Message message, String encodingStyleUri, String targetObjectNamespace, String soapHeader) SoapWrapper.putInEnvelope
(Message message, String encodingStyleUri, String targetObjectNamespace, String soapHeader, String namespaceDefs) SoapWrapper.putInEnvelope
(Message message, String encodingStyleUri, String targetObjectNamespace, String soapHeaderInitial, String namespaceDefs, String soapNamespace, CredentialFactory wsscf, boolean passwordDigest, boolean includeXmlDeclaration) SoapWrapper.signMessage
(Message soapMessage, String user, String password, boolean passwordDigest) protected Message
SoapWrapperPipe.unwrapMessage
(Message message, PipeLineSession session) protected Message
SoapWrapperPipe.wrapMessage
(Message message, String soapHeader, PipeLineSession session) Modifier 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) int
SoapWrapper.getFaultCount
(Message message) protected String
SoapWrapper.getFaultString
(Message message, PipeLineSession session) SoapWrapper.getHeader
(Message message, PipeLineSession session) SoapWrapper.putInEnvelope
(Message message, String encodingStyleUri) SoapWrapper.putInEnvelope
(Message message, String encodingStyleUri, String targetObjectNamespace) SoapWrapper.putInEnvelope
(Message message, String encodingStyleUri, String targetObjectNamespace, String soapHeader) SoapWrapper.putInEnvelope
(Message message, String encodingStyleUri, String targetObjectNamespace, String soapHeader, String namespaceDefs) SoapWrapper.putInEnvelope
(Message message, String encodingStyleUri, String targetObjectNamespace, String soapHeaderInitial, String namespaceDefs, String soapNamespace, CredentialFactory wsscf, boolean passwordDigest, boolean includeXmlDeclaration) SoapWrapper.signMessage
(Message soapMessage, String user, String password, boolean passwordDigest) protected Message
SoapWrapperPipe.unwrapMessage
(Message message, PipeLineSession session) protected Message
SoapWrapperPipe.wrapMessage
(Message message, String soapHeader, PipeLineSession session) -
Uses of Message in org.frankframework.stream
Modifier and TypeMethodDescriptionstatic Message
Message.copyMessage()
Creates a copy of this Message object.MessageOutputStream.getResponse()
MessageOutputStreamCap.getResponse()
static Message
Message.nullMessage()
static Message
Message.nullMessage
(MessageContext context) Modifier and TypeMethodDescriptionstatic boolean
Message.hasDataAvailable
(Message message) Check if a message has any data available.static boolean
Check if the message passed is null or empty.static boolean
void
MessageOutputStream.setResponse
(Message response) Response message, e.g. -
Uses of Message in org.frankframework.util
Modifier and TypeMethodDescriptionstatic Message
MessageUtils.parse
(jakarta.xml.soap.AttachmentPart soapAttachment) static Message
MessageUtils.parseContentAsMessage
(jakarta.servlet.http.HttpServletRequest request) If content is present (POST/PUT) one of the following headers must be set:
Content-Length / Transfer-Encoding
If neither header is present, or the size is0
anullMessage
will be returned.static Message
XmlUtils.removeNamespaces
(Message input) Modifier and TypeMethodDescriptionstatic void
JdbcUtil.applyParameters
(IDbmsSupport dbmsSupport, PreparedStatement statement, ParameterList parameters, Message message, PipeLineSession session) static Element
XmlUtils.buildElement
(Message s) static Charset
MessageUtils.computeDecodingCharset
(Message message) Reads the first 10k bytes of (binary) messages to determine the charset when not present in theMessageContext
.static Charset
MessageUtils.computeDecodingCharset
(Message message, int confidence) Reads the first 10k bytes of (binary) messages to determine the charset when not present in theMessageContext
.static org.springframework.util.MimeType
MessageUtils.computeMimeType
(Message message) Computes theMimeType
when not available.static org.springframework.util.MimeType
MessageUtils.computeMimeType
(Message message, String filename) Computes theMimeType
when not available, attempts to resolve the Charset when of type TEXT.static long
MessageUtils.computeSize
(Message message) Resource intensive operation, calculates the binary size of a Message.static Long
MessageUtils.generateCRC32
(Message message) Resource intensive operation, preserves the message and calculates an CRC32 checksum over the entire message.static String
MessageUtils.generateMD5Hash
(Message message) Resource intensive operation, preserves the message and calculates an MD5 hash over the entire message.static org.springframework.util.MimeType
MessageUtils.getMimeType
(Message message) Returns theMimeType
if present in theMessageContext
.static boolean
MessageUtils.isMimeType
(Message message, org.springframework.util.MimeType compareTo) static boolean
XmlUtils.isWellFormed
(Message input, String root) static Message
XmlUtils.removeNamespaces
(Message input) static String
ModifierConstructorDescriptionMessageDataSource
(Message message) MessageDataSource
(Message message, String newContentType) -
Uses of Message in org.frankframework.validation
Modifier and TypeMethodDescriptionprotected InputSource
AbstractXmlValidator.getInputSource
(Message input)