Uses of Class
org.frankframework.receivers.RawMessageWrapper

Packages that use RawMessageWrapper

Package	Description
org.frankframework.core
org.frankframework.extensions.esb
org.frankframework.extensions.fxf
org.frankframework.extensions.kafka
org.frankframework.extensions.mqtt
org.frankframework.extensions.sap.jco3
org.frankframework.filesystem
org.frankframework.http
org.frankframework.jdbc
org.frankframework.jms
org.frankframework.larva
org.frankframework.messaging.amqp
org.frankframework.receivers
org.frankframework.util

Uses of RawMessageWrapper in org.frankframework.core

Methods in org.frankframework.core that return RawMessageWrapper

Modifier and Type	Method	Description
RawMessageWrapper<M>	IMessageBrowser.browseMessage(String storageKey)	Retrieves the message, but does not delete.
RawMessageWrapper<M>	IHasProcessState.changeProcessState(RawMessageWrapper<M> message, ProcessState toState, String reason)	Change the processState of the message to the specified state, if that state is supported.
RawMessageWrapper<S>	ITransactionalStorage.consumeMessage(String storageKey)	Retrieves and deletes the message.
RawMessageWrapper<M>	ICorrelatedPullingListener.getRawMessage(String correlationId, Map<String,Object> threadContext)	Retrieves messages from queue or other channel, but retrieves only messages with the specified correlationId.
RawMessageWrapper<M>	IPullingListener.getRawMessage(Map<String,Object> threadContext)	Retrieves messages from queue or other channel, but does no processing on it.
RawMessageWrapper<M>	IPushingListener.wrapRawMessage(M rawMessage, PipeLineSession session)	Wrap a raw message in a MessageWrapper.

Methods in org.frankframework.core with parameters of type RawMessageWrapper

Modifier and Type	Method	Description
void	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.
RawMessageWrapper<M>	IHasProcessState.changeProcessState(RawMessageWrapper<M> message, ProcessState toState, String reason)	Change the processState of the message to the specified state, if that state is supported.
Message	IListener.extractMessage(RawMessageWrapper<M> rawMessage, Map<String,Object> context)	Extracts data from message obtained from IPullingListener.getRawMessage(Map) or IPushingListener.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 perform IListener.extractMessage(org.frankframework.receivers.RawMessageWrapper<M>, java.util.Map<java.lang.String, java.lang.Object>) and IListener.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 contains IListener.extractMessage(org.frankframework.receivers.RawMessageWrapper<M>, java.util.Map<java.lang.String, java.lang.Object>) and IListener.afterMessageProcessed(org.frankframework.core.PipeLineResult, org.frankframework.receivers.RawMessageWrapper<M>, org.frankframework.core.PipeLineSession).

Uses of RawMessageWrapper in org.frankframework.extensions.esb

Methods in org.frankframework.extensions.esb with parameters of type RawMessageWrapper

Modifier and Type	Method	Description
void	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 RawMessageWrapper

Modifier and Type	Method	Description
void	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 RawMessageWrapper

Modifier and Type	Method	Description
RawMessageWrapper<org.apache.kafka.clients.consumer.ConsumerRecord<String,byte[]>>	KafkaListener.getRawMessage(Map<String,Object> threadContext)

Methods in org.frankframework.extensions.kafka with parameters of type RawMessageWrapper

Modifier and Type	Method	Description
void	KafkaListener.afterMessageProcessed(PipeLineResult processResult, RawMessageWrapper<org.apache.kafka.clients.consumer.ConsumerRecord<String,byte[]>> rawMessage, PipeLineSession pipeLineSession)
Message	KafkaListener.extractMessage(RawMessageWrapper<org.apache.kafka.clients.consumer.ConsumerRecord<String,byte[]>> wrappedMessage, Map<String,Object> threadContext)

Uses of RawMessageWrapper in org.frankframework.extensions.mqtt

Methods in org.frankframework.extensions.mqtt that return RawMessageWrapper

Modifier and Type	Method	Description
RawMessageWrapper<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 RawMessageWrapper

Modifier and Type	Method	Description
void	MqttListener.afterMessageProcessed(PipeLineResult processResult, RawMessageWrapper<org.eclipse.paho.client.mqttv3.MqttMessage> rawMessage, PipeLineSession pipeLineSession)
Message	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 RawMessageWrapper

Modifier and Type	Method	Description
RawMessageWrapper<M>	SapListenerImpl.wrapRawMessage(M message, PipeLineSession session)

Methods in org.frankframework.extensions.sap.jco3 with parameters of type RawMessageWrapper

Modifier and Type	Method	Description
void	SapListenerImpl.afterMessageProcessed(PipeLineResult processResult, RawMessageWrapper<M> rawMessageWrapper, PipeLineSession pipeLineSession)
Message	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 RawMessageWrapper

Modifier and Type	Method	Description
RawMessageWrapper<F>	FileSystemMessageBrowser.browseMessage(String storageKey)
RawMessageWrapper<F>	AbstractFileSystemListener.changeProcessState(RawMessageWrapper<F> message, ProcessState toState, String reason)
RawMessageWrapper<F>	AbstractFileSystemListener.getRawMessage(Map<String,Object> threadContext)

Methods in org.frankframework.filesystem with parameters of type RawMessageWrapper

Modifier and Type	Method	Description
void	AbstractFileSystemListener.afterMessageProcessed(PipeLineResult processResult, RawMessageWrapper<F> rawMessage, PipeLineSession pipeLineSession)
RawMessageWrapper<F>	AbstractFileSystemListener.changeProcessState(RawMessageWrapper<F> message, ProcessState toState, String reason)
Message	AbstractFileSystemListener.extractMessage(RawMessageWrapper<F> rawMessage, Map<String,Object> context)	Returns the filename, or the contents
Message	AbstractMailListener.extractMessage(RawMessageWrapper<M> rawMessage, Map<String,Object> context)

Constructors in org.frankframework.filesystem with parameters of type RawMessageWrapper

Modifier	Constructor	Description
	FileSystemMessageBrowsingIteratorItem(FS fileSystem, RawMessageWrapper<F> item, String messageIdPropertyKey)

Uses of RawMessageWrapper in org.frankframework.http

Methods in org.frankframework.http that return RawMessageWrapper

Modifier and Type	Method	Description
RawMessageWrapper<Message>	PushingListenerAdapter.wrapRawMessage(Message rawMessage, PipeLineSession session)

Methods in org.frankframework.http with parameters of type RawMessageWrapper

Modifier and Type	Method	Description
void	PushingListenerAdapter.afterMessageProcessed(PipeLineResult processResult, RawMessageWrapper<Message> rawMessage, PipeLineSession pipeLineSession)
Message	PushingListenerAdapter.extractMessage(RawMessageWrapper<Message> rawMessage, Map<String,Object> context)

Uses of RawMessageWrapper in org.frankframework.jdbc

Methods in org.frankframework.jdbc that return RawMessageWrapper

Modifier and Type	Method	Description
RawMessageWrapper<M>	AbstractJdbcMessageBrowser.browseMessage(String storageKey)
protected RawMessageWrapper<M>	JdbcListener.changeProcessState(Connection connection, RawMessageWrapper<M> rawMessage, ProcessState toState, String reason)
RawMessageWrapper<M>	JdbcListener.changeProcessState(RawMessageWrapper<M> rawMessage, ProcessState toState, String reason)
protected RawMessageWrapper<M>	JdbcTableListener.changeProcessState(Connection connection, RawMessageWrapper<M> rawMessage, ProcessState toState, String reason)
RawMessageWrapper<S>	JdbcTransactionalStorage.consumeMessage(String storageKey)	Retrieves and deletes the message.
protected RawMessageWrapper<M>	JdbcListener.extractRawMessage(ResultSet rs)	This method returns a MessageWrapper containing contents of the message stored in the database.
protected RawMessageWrapper<Serializable>	MessageStoreListener.extractRawMessage(ResultSet rs)
protected RawMessageWrapper<M>	JdbcListener.getRawMessage(Connection conn, Map<String,Object> threadContext)
RawMessageWrapper<M>	JdbcListener.getRawMessage(Map<String,Object> threadContext)
protected RawMessageWrapper<String>	SimpleJdbcListener.getRawMessage(Connection conn, Map<String,Object> threadContext)
RawMessageWrapper<String>	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 RawMessageWrapper

Modifier and Type	Method	Description
protected 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)
RawMessageWrapper<M>	JdbcListener.changeProcessState(RawMessageWrapper<M> rawMessage, ProcessState toState, String reason)
protected RawMessageWrapper<M>	JdbcTableListener.changeProcessState(Connection connection, RawMessageWrapper<M> rawMessage, ProcessState toState, String reason)
Message	JdbcListener.extractMessage(RawMessageWrapper<M> rawMessage, Map<String,Object> context)
Message	MessageStoreListener.extractMessage(RawMessageWrapper<Serializable> rawMessageWrapper, Map<String,Object> context)
Message	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 RawMessageWrapper

Modifier and Type	Method	Description
RawMessageWrapper<M>	JmsBrowser.browseMessage(String messageId)
RawMessageWrapper<S>	JmsTransactionalStorage.browseMessage(String storageKey)
RawMessageWrapper<S>	JmsTransactionalStorage.consumeMessage(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 RawMessageWrapper

Modifier and Type	Method	Description
void	AbstractJmsListener.afterMessageProcessed(PipeLineResult plr, RawMessageWrapper<jakarta.jms.Message> rawMessageWrapper, PipeLineSession session)
void	PullingJmsListener.afterMessageProcessed(PipeLineResult plr, RawMessageWrapper<jakarta.jms.Message> rawMessageWrapper, PipeLineSession pipeLineSession)
Message	AbstractJmsListener.extractMessage(RawMessageWrapper<jakarta.jms.Message> rawMessage, Map<String,Object> context)	Extracts data from message obtained from IPullingListener.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 RawMessageWrapper

Modifier and Type	Method	Description
void	ListenerMessageHandler.processRawMessage(IListener<M> origin, RawMessageWrapper<M> rawMessage, PipeLineSession threadContext, boolean duplicatesAlreadyChecked)

Uses of RawMessageWrapper in org.frankframework.messaging.amqp

Methods in org.frankframework.messaging.amqp that return RawMessageWrapper

Modifier and Type	Method	Description
RawMessageWrapper<org.apache.qpid.protonj2.client.Message<?>>	AmqpListener.wrapRawMessage(org.apache.qpid.protonj2.client.Message<?> rawMessage, PipeLineSession session)

Methods in org.frankframework.messaging.amqp with parameters of type RawMessageWrapper

Modifier and Type	Method	Description
void	AmqpListener.afterMessageProcessed(PipeLineResult processResult, RawMessageWrapper<org.apache.qpid.protonj2.client.Message<?>> rawMessage, PipeLineSession pipeLineSession)
Message	AmqpListener.extractMessage(RawMessageWrapper<org.apache.qpid.protonj2.client.Message<?>> rawMessage, Map<String,Object> context)

Uses of RawMessageWrapper in org.frankframework.receivers

Subclasses of RawMessageWrapper in org.frankframework.receivers

Modifier and Type	Class	Description
class	MessageWrapper<M>	Wrapper for messages that are not serializable.

Methods in org.frankframework.receivers that return RawMessageWrapper

Modifier and Type	Method	Description
RawMessageWrapper<M>	Receiver.changeProcessState(RawMessageWrapper<M> message, ProcessState toState, String reason)	Change message process state, via the listener of the receiver.
RawMessageWrapper<M>	JavaListener.wrapRawMessage(M rawMessage, PipeLineSession session)

Methods in org.frankframework.receivers with parameters of type RawMessageWrapper

Modifier and Type	Method	Description
void	FrankListener.afterMessageProcessed(PipeLineResult processResult, RawMessageWrapper<Message> rawMessage, PipeLineSession pipeLineSession)
void	JavaListener.afterMessageProcessed(PipeLineResult processResult, RawMessageWrapper<M> rawMessage, PipeLineSession pipeLineSession)
RawMessageWrapper<M>	Receiver.changeProcessState(RawMessageWrapper<M> message, ProcessState toState, String reason)	Change message process state, via the listener of the receiver.
Message	FrankListener.extractMessage(RawMessageWrapper<Message> rawMessage, Map<String,Object> context)
Message	JavaListener.extractMessage(RawMessageWrapper<M> rawMessage, Map<String,Object> context)
String	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.
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 RawMessageWrapper

Modifier	Constructor	Description
	MessageWrapper(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 RawMessageWrapper

Modifier and Type	Method	Description
static String	MessageBrowsingUtil.getMessageText(RawMessageWrapper<?> rawMessageWrapper, IListener listener)