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) 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)
void
IMessageHandler.processRawMessage
(IListener<M> origin, RawMessageWrapper<M> message, PipeLineSession session, long waitingTime, boolean duplicatesAlreadyChecked) Same asIMessageHandler.processRawMessage(IListener,RawMessageWrapper,PipeLineSession, boolean)
, but now updates IdleStatistics tooIMessageHandler.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 TypeMethodDescriptionJdbcMessageBrowser.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>
JdbcMessageBrowser.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
JmsListenerBase.afterMessageProcessed
(PipeLineResult plr, RawMessageWrapper<jakarta.jms.Message> rawMessageWrapper, PipeLineSession session) void
PullingJmsListener.afterMessageProcessed
(PipeLineResult plr, RawMessageWrapper<jakarta.jms.Message> rawMessageWrapper, PipeLineSession pipeLineSession) JmsListenerBase.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) FileRecordListener.getRawMessage
(Map<String, Object> threadContext) Deprecated.Retrieves a single record from a file.JavaListener.wrapRawMessage
(M rawMessage, PipeLineSession session) Modifier and TypeMethodDescriptionvoid
FileRecordListener.afterMessageProcessed
(PipeLineResult processResult, RawMessageWrapper<String> rawMessage, PipeLineSession pipeLineSession) Deprecated.void
JavaListener.afterMessageProcessed
(PipeLineResult processResult, RawMessageWrapper<M> rawMessage, PipeLineSession pipeLineSession) Receiver.changeProcessState
(RawMessageWrapper<M> message, ProcessState toState, String reason) FileRecordListener.extractMessage
(RawMessageWrapper<String> rawMessage, Map<String, Object> context) Deprecated.JavaListener.extractMessage
(RawMessageWrapper<M> rawMessage, Map<String, Object> context) int
Receiver.getDeliveryCount
(RawMessageWrapper<M> rawMessage) void
Receiver.moveInProcessToError
(RawMessageWrapper<M> rawMessageWrapper, Map<String, Object> context, 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 duplicatesAlreadyChecked) void
Receiver.processRawMessage
(IListener<M> origin, RawMessageWrapper<M> rawMessage, PipeLineSession session, long waitingDuration, boolean duplicatesAlreadyChecked) Receiver.processRequest
(IListener<M> origin, RawMessageWrapper<M> rawMessage, Message message, PipeLineSession session) Process the received message withReceiver.processRequest(IListener, RawMessageWrapper, Message, PipeLineSession)
.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)