Uses of Class
org.frankframework.receivers.RawMessageWrapper
Package
Description
-
Uses of RawMessageWrapper in org.frankframework.core
Modifier and TypeMethodDescriptionIMessageBrowser.browseMessage
(String storageKey) Retrieves the message, but does not delete.IHasProcessState.changeProcessState
(RawMessageWrapper<M> message, ProcessState toState, String reason) Change the processState of the message to the specified state, if that state is supported.ITransactionalStorage.getMessage
(String storageKey) Retrieves and deletes the message.ICorrelatedPullingListener.getRawMessage
(String correlationId, Map<String, Object> threadContext) Retrieves messages from queue or other channel, but retrieves only messages with the specified correlationId.IPullingListener.getRawMessage
(Map<String, Object> threadContext) Retrieves messages from queue or other channel, but does no processing on it.IPostboxListener.retrieveRawMessage
(String messageSelector, Map<String, Object> threadContext) Deprecated, for removal: This API element is subject to removal in a future version.Retrieves the first message found from queue or other channel, that matches the specifiedmessageSelector
.IPushingListener.wrapRawMessage
(M rawMessage, PipeLineSession session) Wrap a raw message in a MessageWrapper.Modifier and TypeMethodDescriptionvoid
IListener.afterMessageProcessed
(PipeLineResult processResult, RawMessageWrapper<M> rawMessage, PipeLineSession pipeLineSession) Called to perform actions (like committing or sending a reply) after a message has been processed by the Pipeline.IHasProcessState.changeProcessState
(RawMessageWrapper<M> message, ProcessState toState, String reason) Change the processState of the message to the specified state, if that state is supported.IListener.extractMessage
(RawMessageWrapper<M> rawMessage, Map<String, Object> context) Extracts data from message obtained fromIPullingListener.getRawMessage(Map)
orIPushingListener.wrapRawMessage(Object, PipeLineSession)
.int
IKnowsDeliveryCount.getDeliveryCount
(RawMessageWrapper<M> rawMessage) void
IMessageHandler.processRawMessage
(IListener<M> origin, RawMessageWrapper<M> message, PipeLineSession session, boolean duplicatesAlreadyChecked) Will use listener to performIListener.extractMessage(org.frankframework.receivers.RawMessageWrapper<M>, java.util.Map<java.lang.String, java.lang.Object>)
andIListener.afterMessageProcessed(org.frankframework.core.PipeLineResult, org.frankframework.receivers.RawMessageWrapper<M>, org.frankframework.core.PipeLineSession)
IMessageHandler.processRequest
(IListener<M> origin, RawMessageWrapper<M> rawMessage, Message message, PipeLineSession session) Alternative to functions above, will NOT useIListener.extractMessage(org.frankframework.receivers.RawMessageWrapper<M>, java.util.Map<java.lang.String, java.lang.Object>)
. -
Uses of RawMessageWrapper in org.frankframework.http
Modifier and TypeMethodDescriptionPushingListenerAdapter.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) -
Uses of RawMessageWrapper in org.frankframework.jdbc
Modifier and TypeMethodDescriptionAbstractJdbcMessageBrowser.browseMessage
(String storageKey) protected RawMessageWrapper<M>
JdbcListener.changeProcessState
(Connection connection, RawMessageWrapper<M> rawMessage, ProcessState toState, String reason) JdbcListener.changeProcessState
(RawMessageWrapper<M> rawMessage, ProcessState toState, String reason) protected RawMessageWrapper<M>
JdbcTableListener.changeProcessState
(Connection connection, RawMessageWrapper<M> rawMessage, ProcessState toState, String reason) JdbcTransactionalStorage.getMessage
(String storageKey) protected RawMessageWrapper<M>
JdbcListener.getRawMessage
(Connection conn, Map<String, Object> threadContext) JdbcListener.getRawMessage
(Map<String, Object> threadContext) protected RawMessageWrapper<String>
SimpleJdbcListener.getRawMessage
(Connection conn, Map<String, Object> threadContext) SimpleJdbcListener.getRawMessage
(Map<String, Object> threadContext) protected abstract RawMessageWrapper<M>
AbstractJdbcMessageBrowser.retrieveObject
(String storageKey, ResultSet rs, int columnIndex) protected RawMessageWrapper<M>
JdbcTableMessageBrowser.retrieveObject
(String storageKey, ResultSet rs, int columnIndex) protected RawMessageWrapper<S>
JdbcTransactionalStorage.retrieveObject
(String storageKey, ResultSet rs, int columnIndex) Modifier and TypeMethodDescriptionvoid
JdbcListener.afterMessageProcessed
(PipeLineResult processResult, RawMessageWrapper<M> rawMessage, PipeLineSession pipeLineSession) void
SimpleJdbcListener.afterMessageProcessed
(PipeLineResult processResult, RawMessageWrapper<String> rawMessage, PipeLineSession pipeLineSession) protected RawMessageWrapper<M>
JdbcListener.changeProcessState
(Connection connection, RawMessageWrapper<M> rawMessage, ProcessState toState, String reason) JdbcListener.changeProcessState
(RawMessageWrapper<M> rawMessage, ProcessState toState, String reason) protected RawMessageWrapper<M>
JdbcTableListener.changeProcessState
(Connection connection, RawMessageWrapper<M> rawMessage, ProcessState toState, String reason) 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 String
JdbcListener.getKeyFromRawMessage
(RawMessageWrapper<M> rawMessage) -
Uses of RawMessageWrapper in org.frankframework.jms
Modifier and TypeMethodDescriptionJmsBrowser.browseMessage
(String messageId) JmsTransactionalStorage.browseMessage
(String storageKey) JmsTransactionalStorage.getMessage
(String storageKey) RawMessageWrapper<jakarta.jms.Message>
PullingJmsListener.getRawMessage
(String correlationId, Map<String, Object> threadContext) RawMessageWrapper<jakarta.jms.Message>
PullingJmsListener.getRawMessage
(Map<String, Object> threadContext) Retrieves messages from queue or other channel, but does no processing on it.RawMessageWrapper<jakarta.jms.Message>
PullingJmsListener.retrieveRawMessage
(String messageSelector, Map<String, Object> threadContext) RawMessageWrapper<jakarta.jms.Message>
PushingJmsListener.wrapRawMessage
(jakarta.jms.Message rawMessage, PipeLineSession session) Modifier and TypeMethodDescriptionvoid
AbstractJmsListener.afterMessageProcessed
(PipeLineResult plr, RawMessageWrapper<jakarta.jms.Message> rawMessageWrapper, PipeLineSession session) void
PullingJmsListener.afterMessageProcessed
(PipeLineResult plr, RawMessageWrapper<jakarta.jms.Message> rawMessageWrapper, PipeLineSession pipeLineSession) AbstractJmsListener.extractMessage
(RawMessageWrapper<jakarta.jms.Message> rawMessage, Map<String, Object> context) Extracts data from message obtained fromIPullingListener.getRawMessage(Map)
.int
PushingJmsListener.getDeliveryCount
(RawMessageWrapper<jakarta.jms.Message> rawMessage) -
Uses of RawMessageWrapper in org.frankframework.receivers
Modifier and TypeClassDescriptionclass
Wrapper for messages that are not serializable.Modifier and TypeMethodDescriptionReceiver.changeProcessState
(RawMessageWrapper<M> message, ProcessState toState, String reason) Change message process state, via the listener of the receiver.FrankListener.wrapRawMessage
(Message rawMessage, PipeLineSession session) JavaListener.wrapRawMessage
(M rawMessage, PipeLineSession session) Modifier and TypeMethodDescriptionvoid
FrankListener.afterMessageProcessed
(PipeLineResult processResult, RawMessageWrapper<Message> rawMessage, PipeLineSession pipeLineSession) void
JavaListener.afterMessageProcessed
(PipeLineResult processResult, RawMessageWrapper<M> rawMessage, PipeLineSession pipeLineSession) Receiver.changeProcessState
(RawMessageWrapper<M> message, ProcessState toState, String reason) Change message process state, via the listener of the receiver.FrankListener.extractMessage
(RawMessageWrapper<Message> rawMessage, Map<String, Object> context) JavaListener.extractMessage
(RawMessageWrapper<M> rawMessage, Map<String, Object> context) Receiver.getCachedErrorMessage
(RawMessageWrapper<M> rawMessageWrapper) int
Receiver.getDeliveryCount
(RawMessageWrapper<M> rawMessage) Get the delivery-count for the message.protected boolean
Receiver.isDeliveryRetryLimitExceededAfterMessageProcessed
(RawMessageWrapper<M> messageWrapper) Returns true if the message should no longer be retried after it has failed in processing.protected boolean
Receiver.isDeliveryRetryLimitExceededBeforeMessageProcessing
(RawMessageWrapper<M> rawMessageWrapper, PipeLineSession session, boolean manualRetry) returns true if message should not be processed when it is delivered.void
Receiver.moveInProcessToError
(RawMessageWrapper<M> rawMessageWrapper, PipeLineSession session, Instant receivedDate, String comments, org.springframework.transaction.TransactionDefinition txDef) Move a message from the "in process" state or storage, to the error state or storage.void
Receiver.processRawMessage
(IListener<M> origin, RawMessageWrapper<M> rawMessage, PipeLineSession session, boolean retryStatusAlreadyChecked) This method processes the raw message from the listener.Receiver.processRequest
(IListener<M> origin, RawMessageWrapper<M> rawMessage, Message message, PipeLineSession session) Process the received message withIMessageHandler.processRequest(IListener, RawMessageWrapper, Message, PipeLineSession)
.protected Receiver.ProcessStatusCacheItem
Receiver.updateMessageReceiveCount
(RawMessageWrapper<M> rawMessageWrapper) Call this method exactly once per every try to process a message to initialize the internally cached receive-count for the messageId.ModifierConstructorDescriptionMessageWrapper
(RawMessageWrapper<M> rawMessageWrapper, Message message) MessageWrapper
(RawMessageWrapper<M> rawMessageWrapper, Message message, String messageId, String correlationId) -
Uses of RawMessageWrapper in org.frankframework.util
Modifier and TypeMethodDescriptionstatic String
MessageBrowsingUtil.getMessageText
(RawMessageWrapper<?> rawMessageWrapper, IListener listener)