Uses of Class
org.frankframework.receivers.RawMessageWrapper
Packages that use RawMessageWrapper
Package
Description
-
Uses of RawMessageWrapper in org.frankframework.core
Methods in org.frankframework.core that return RawMessageWrapperModifier 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.IPushingListener.wrapRawMessage
(M rawMessage, PipeLineSession session) Wrap a raw message in a MessageWrapper.Methods in org.frankframework.core with parameters of type RawMessageWrapperModifier 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.extensions.esb
Methods in org.frankframework.extensions.esb with parameters of type RawMessageWrapperModifier and TypeMethodDescriptionvoid
EsbJmsListener.afterMessageProcessed
(PipeLineResult plr, RawMessageWrapper<jakarta.jms.Message> rawMessageWrapper, PipeLineSession pipeLineSession) -
Uses of RawMessageWrapper in org.frankframework.extensions.fxf
Methods in org.frankframework.extensions.fxf with parameters of type RawMessageWrapperModifier and TypeMethodDescriptionvoid
FxfListener.afterMessageProcessed
(PipeLineResult plr, RawMessageWrapper<jakarta.jms.Message> rawMessageWrapper, PipeLineSession pipeLineSession) -
Uses of RawMessageWrapper in org.frankframework.extensions.kafka
Methods in org.frankframework.extensions.kafka that return RawMessageWrapperModifier and TypeMethodDescriptionRawMessageWrapper
<org.apache.kafka.clients.consumer.ConsumerRecord<String, byte[]>> KafkaListener.getRawMessage
(Map<String, Object> threadContext) Deprecated.Methods in org.frankframework.extensions.kafka with parameters of type RawMessageWrapperModifier and TypeMethodDescriptionvoid
KafkaListener.afterMessageProcessed
(PipeLineResult processResult, RawMessageWrapper<org.apache.kafka.clients.consumer.ConsumerRecord<String, byte[]>> rawMessage, PipeLineSession pipeLineSession) Deprecated.KafkaListener.extractMessage
(RawMessageWrapper<org.apache.kafka.clients.consumer.ConsumerRecord<String, byte[]>> wrappedMessage, Map<String, Object> threadContext) Deprecated. -
Uses of RawMessageWrapper in org.frankframework.extensions.mqtt
Methods in org.frankframework.extensions.mqtt that return RawMessageWrapperModifier and TypeMethodDescriptionRawMessageWrapper
<org.eclipse.paho.client.mqttv3.MqttMessage> MqttListener.wrapRawMessage
(org.eclipse.paho.client.mqttv3.MqttMessage message, PipeLineSession session) Methods in org.frankframework.extensions.mqtt with parameters of type RawMessageWrapperModifier and TypeMethodDescriptionvoid
MqttListener.afterMessageProcessed
(PipeLineResult processResult, RawMessageWrapper<org.eclipse.paho.client.mqttv3.MqttMessage> rawMessage, PipeLineSession pipeLineSession) MqttListener.extractMessage
(RawMessageWrapper<org.eclipse.paho.client.mqttv3.MqttMessage> rawMessage, Map<String, Object> context) -
Uses of RawMessageWrapper in org.frankframework.extensions.sap.jco3
Methods in org.frankframework.extensions.sap.jco3 that return RawMessageWrapperModifier and TypeMethodDescriptionSapListenerImpl.wrapRawMessage
(M message, PipeLineSession session) Methods in org.frankframework.extensions.sap.jco3 with parameters of type RawMessageWrapperModifier and TypeMethodDescriptionvoid
SapListenerImpl.afterMessageProcessed
(PipeLineResult processResult, RawMessageWrapper<M> rawMessageWrapper, PipeLineSession pipeLineSession) SapListenerImpl.extractMessage
(RawMessageWrapper<M> rawMessageWrapper, Map<String, Object> context) Called by handler.processRawMessage, NEVER by handler.processRequest. -
Uses of RawMessageWrapper in org.frankframework.filesystem
Methods in org.frankframework.filesystem that return RawMessageWrapperModifier and TypeMethodDescriptionFileSystemMessageBrowser.browseMessage
(String storageKey) AbstractFileSystemListener.changeProcessState
(RawMessageWrapper<F> message, ProcessState toState, String reason) AbstractFileSystemListener.getRawMessage
(Map<String, Object> threadContext) Methods in org.frankframework.filesystem with parameters of type RawMessageWrapperModifier and TypeMethodDescriptionvoid
AbstractFileSystemListener.afterMessageProcessed
(PipeLineResult processResult, RawMessageWrapper<F> rawMessage, PipeLineSession pipeLineSession) AbstractFileSystemListener.changeProcessState
(RawMessageWrapper<F> message, ProcessState toState, String reason) AbstractFileSystemListener.extractMessage
(RawMessageWrapper<F> rawMessage, Map<String, Object> context) Returns the filename, or the contentsAbstractMailListener.extractMessage
(RawMessageWrapper<M> rawMessage, Map<String, Object> context) Constructors in org.frankframework.filesystem with parameters of type RawMessageWrapperModifierConstructorDescriptionFileSystemMessageBrowsingIteratorItem
(FS fileSystem, RawMessageWrapper<F> item, String messageIdPropertyKey) -
Uses of RawMessageWrapper in org.frankframework.http
Methods in org.frankframework.http that return RawMessageWrapperModifier and TypeMethodDescriptionPushingListenerAdapter.wrapRawMessage
(Message rawMessage, PipeLineSession session) Methods in org.frankframework.http with parameters of type RawMessageWrapperModifier 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
Methods in org.frankframework.jdbc that return RawMessageWrapperModifier 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) protected RawMessageWrapper
<M> JdbcListener.extractRawMessage
(ResultSet rs) This method returns aMessageWrapper
containing contents of the message stored in the database.protected RawMessageWrapper
<Serializable> MessageStoreListener.extractRawMessage
(ResultSet rs) 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) Methods in org.frankframework.jdbc with parameters of type RawMessageWrapperModifier and TypeMethodDescriptionprotected <M> void
JdbcListener.addAdditionalQueryFieldsToSession
(RawMessageWrapper<M> rawMessage, Map<String, Object> context) protected void
JdbcListener.addAdditionalValuesToMessageWrapper
(ResultSet rs, RawMessageWrapper<M> mw) void
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<Serializable> rawMessageWrapper, 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
Methods in org.frankframework.jms that return RawMessageWrapperModifier 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> PushingJmsListener.wrapRawMessage
(jakarta.jms.Message rawMessage, PipeLineSession session) Methods in org.frankframework.jms with parameters of type RawMessageWrapperModifier 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.larva
Methods in org.frankframework.larva with parameters of type RawMessageWrapperModifier and TypeMethodDescriptionvoid
ListenerMessageHandler.processRawMessage
(IListener<M> origin, RawMessageWrapper<M> rawMessage, PipeLineSession threadContext, boolean duplicatesAlreadyChecked) ListenerMessageHandler.processRequest
(IListener<M> origin, RawMessageWrapper<M> rawMessage, Message message, PipeLineSession session) -
Uses of RawMessageWrapper in org.frankframework.receivers
Subclasses of RawMessageWrapper in org.frankframework.receiversModifier and TypeClassDescriptionclass
Wrapper for messages that are not serializable.Methods in org.frankframework.receivers that return RawMessageWrapperModifier 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) Methods in org.frankframework.receivers with parameters of type RawMessageWrapperModifier 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.Constructors in org.frankframework.receivers with parameters of type RawMessageWrapperModifierConstructorDescriptionMessageWrapper
(RawMessageWrapper<M> rawMessageWrapper, Message message) MessageWrapper
(RawMessageWrapper<M> rawMessageWrapper, Message message, String messageId, String correlationId) -
Uses of RawMessageWrapper in org.frankframework.util
Methods in org.frankframework.util with parameters of type RawMessageWrapperModifier and TypeMethodDescriptionstatic String
MessageBrowsingUtil.getMessageText
(RawMessageWrapper<?> rawMessageWrapper, IListener listener)