Uses of Interface
org.springframework.amqp.core.MessagePostProcessor

Packages that use MessagePostProcessor

Package	Description
org.springframework.amqp.core	Provides core classes for the spring AMQP abstraction.
org.springframework.amqp.rabbit	Provides top-level classes for Spring Rabbit.
org.springframework.amqp.rabbit.config	Provides classes supporting the Rabbit XML namespace.
org.springframework.amqp.rabbit.core	Provides core classes for Spring Rabbit.
org.springframework.amqp.rabbit.listener	Provides classes for message listener containers.
org.springframework.amqp.rabbit.listener.adapter	Provides classes for adapting listeners.
org.springframework.amqp.support.postprocessor	Package for Spring AMQP message post processors.
org.springframework.rabbit.stream.producer	Provides classes for stream producers.

Uses of MessagePostProcessor in org.springframework.amqp.core

Methods in org.springframework.amqp.core with parameters of type MessagePostProcessor

Modifier and Type	Method	Description
void	AmqpTemplate.convertAndSend(Object message, MessagePostProcessor messagePostProcessor)	Convert a Java object to an Amqp Message and send it to a default exchange with a default routing key.
void	AmqpTemplate.convertAndSend(String routingKey, Object message, MessagePostProcessor messagePostProcessor)	Convert a Java object to an Amqp Message and send it to a default exchange with a specific routing key.
void	AmqpTemplate.convertAndSend(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor)	Convert a Java object to an Amqp Message and send it to a specific exchange with a specific routing key.
Object	AmqpTemplate.convertSendAndReceive(Object message, MessagePostProcessor messagePostProcessor)	Basic RPC pattern with conversion.
Object	AmqpTemplate.convertSendAndReceive(String routingKey, Object message, MessagePostProcessor messagePostProcessor)	Basic RPC pattern with conversion.
Object	AmqpTemplate.convertSendAndReceive(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor)	Basic RPC pattern with conversion.
<C> CompletableFuture<C>	AsyncAmqpTemplate.convertSendAndReceive(Object object, MessagePostProcessor messagePostProcessor)	Convert the object to a message and send it to the default exchange with the default routing key after invoking the MessagePostProcessor.
<C> CompletableFuture<C>	AsyncAmqpTemplate.convertSendAndReceive(String routingKey, Object object, MessagePostProcessor messagePostProcessor)	Convert the object to a message and send it to the default exchange with the provided routing key after invoking the MessagePostProcessor.
<C> CompletableFuture<C>	AsyncAmqpTemplate.convertSendAndReceive(String exchange, String routingKey, Object object, MessagePostProcessor messagePostProcessor)	Convert the object to a message and send it to the provided exchange and routing key after invoking the MessagePostProcessor.
<T> T	AmqpTemplate.convertSendAndReceiveAsType(Object message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType)	Basic RPC pattern with conversion.
<T> T	AmqpTemplate.convertSendAndReceiveAsType(String routingKey, Object message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType)	Basic RPC pattern with conversion.
<T> T	AmqpTemplate.convertSendAndReceiveAsType(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType)	Basic RPC pattern with conversion.
<C> CompletableFuture<C>	AsyncAmqpTemplate.convertSendAndReceiveAsType(Object object, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<C> responseType)	Convert the object to a message and send it to the default exchange with the default routing key after invoking the MessagePostProcessor.
<C> CompletableFuture<C>	AsyncAmqpTemplate.convertSendAndReceiveAsType(String routingKey, Object object, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<C> responseType)	Convert the object to a message and send it to the default exchange with the provided routing key after invoking the MessagePostProcessor.
<C> CompletableFuture<C>	AsyncAmqpTemplate.convertSendAndReceiveAsType(String exchange, String routingKey, Object object, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<C> responseType)	Convert the object to a message and send it to the provided exchange and routing key after invoking the MessagePostProcessor.

Uses of MessagePostProcessor in org.springframework.amqp.rabbit

Methods in org.springframework.amqp.rabbit with parameters of type MessagePostProcessor

Modifier and Type	Method	Description
<C> RabbitConverterFuture<C>	AsyncRabbitTemplate.convertSendAndReceive(Object object, MessagePostProcessor messagePostProcessor)
<C> RabbitConverterFuture<C>	AsyncRabbitTemplate.convertSendAndReceive(String routingKey, Object object, MessagePostProcessor messagePostProcessor)
<C> RabbitConverterFuture<C>	AsyncRabbitTemplate.convertSendAndReceive(String exchange, String routingKey, Object object, MessagePostProcessor messagePostProcessor)
<C> RabbitConverterFuture<C>	AsyncRabbitTemplate.convertSendAndReceiveAsType(Object object, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<C> responseType)
<C> RabbitConverterFuture<C>	AsyncRabbitTemplate.convertSendAndReceiveAsType(String routingKey, Object object, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<C> responseType)
<C> RabbitConverterFuture<C>	AsyncRabbitTemplate.convertSendAndReceiveAsType(String exchange, String routingKey, Object object, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<C> responseType)

Uses of MessagePostProcessor in org.springframework.amqp.rabbit.config

Methods in org.springframework.amqp.rabbit.config with parameters of type MessagePostProcessor

Modifier and Type	Method	Description
void	AbstractRabbitListenerContainerFactory.setAfterReceivePostProcessors(MessagePostProcessor... postProcessors)	Set post processors which will be applied after the Message is received.
void	ListenerContainerFactoryBean.setAfterReceivePostProcessors(MessagePostProcessor... afterReceivePostProcessors)
void	BaseRabbitListenerContainerFactory.setBeforeSendReplyPostProcessors(MessagePostProcessor... postProcessors)	Set post processors that will be applied before sending replies; added to each message listener adapter.

Uses of MessagePostProcessor in org.springframework.amqp.rabbit.core

Methods in org.springframework.amqp.rabbit.core that return types with arguments of type MessagePostProcessor

Modifier and Type	Method	Description
Collection<MessagePostProcessor>	RabbitTemplate.getAfterReceivePostProcessors()	Return configured after receive MessagePostProcessors or null.

Methods in org.springframework.amqp.rabbit.core with parameters of type MessagePostProcessor

Modifier and Type	Method	Description
void	RabbitTemplate.addAfterReceivePostProcessors(MessagePostProcessor... afterReceivePostProcessors)	Add MessagePostProcessor that will be invoked immediately after a Channel#basicGet() and before any message conversion is performed.
void	RabbitTemplate.addBeforePublishPostProcessors(MessagePostProcessor... beforePublishPostProcessors)	Add MessagePostProcessor that will be invoked immediately before invoking Channel#basicPublish(), after all other processing, except creating the AMQP.BasicProperties from MessageProperties.
void	RabbitOperations.convertAndSend(Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData)	Convert a Java object to an Amqp Message and send it to a default exchange with a default routing key.
void	RabbitOperations.convertAndSend(String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData)	Convert a Java object to an Amqp Message and send it to a default exchange with a specific routing key.
void	RabbitOperations.convertAndSend(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData)	Convert a Java object to an Amqp Message and send it to a specific exchange with a specific routing key.
void	RabbitTemplate.convertAndSend(Object message, MessagePostProcessor messagePostProcessor)
void	RabbitTemplate.convertAndSend(Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData)
void	RabbitTemplate.convertAndSend(String routingKey, Object message, MessagePostProcessor messagePostProcessor)
void	RabbitTemplate.convertAndSend(String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData)
void	RabbitTemplate.convertAndSend(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor)
void	RabbitTemplate.convertAndSend(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData)
Object	RabbitOperations.convertSendAndReceive(Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData)	Basic RPC pattern with conversion.
Object	RabbitOperations.convertSendAndReceive(String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData)	Basic RPC pattern with conversion.
Object	RabbitOperations.convertSendAndReceive(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData)	Basic RPC pattern with conversion.
Object	RabbitTemplate.convertSendAndReceive(Object message, MessagePostProcessor messagePostProcessor)
Object	RabbitTemplate.convertSendAndReceive(Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData)
Object	RabbitTemplate.convertSendAndReceive(String routingKey, Object message, MessagePostProcessor messagePostProcessor)
Object	RabbitTemplate.convertSendAndReceive(String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData)
Object	RabbitTemplate.convertSendAndReceive(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor)
Object	RabbitTemplate.convertSendAndReceive(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData)
<T> T	RabbitOperations.convertSendAndReceiveAsType(Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData, ParameterizedTypeReference<T> responseType)	Basic RPC pattern with conversion.
<T> T	RabbitOperations.convertSendAndReceiveAsType(String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData, ParameterizedTypeReference<T> responseType)	Basic RPC pattern with conversion.
<T> T	RabbitOperations.convertSendAndReceiveAsType(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData, ParameterizedTypeReference<T> responseType)	Basic RPC pattern with conversion.
<T> T	RabbitTemplate.convertSendAndReceiveAsType(Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData, ParameterizedTypeReference<T> responseType)
<T> T	RabbitTemplate.convertSendAndReceiveAsType(Object message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType)
<T> T	RabbitTemplate.convertSendAndReceiveAsType(String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData, ParameterizedTypeReference<T> responseType)
<T> T	RabbitTemplate.convertSendAndReceiveAsType(String routingKey, Object message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType)
<T> T	RabbitTemplate.convertSendAndReceiveAsType(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData, ParameterizedTypeReference<T> responseType)
<T> T	RabbitTemplate.convertSendAndReceiveAsType(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType)
protected Message	RabbitTemplate.convertSendAndReceiveRaw(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData)	Convert and send a message and return the raw reply message, or null.
boolean	RabbitTemplate.removeAfterReceivePostProcessor(MessagePostProcessor afterReceivePostProcessor)	Remove the provided MessagePostProcessor from the RabbitTemplate.afterReceivePostProcessors list.
boolean	RabbitTemplate.removeBeforePublishPostProcessor(MessagePostProcessor beforePublishPostProcessor)	Remove the provided MessagePostProcessor from the RabbitTemplate.beforePublishPostProcessors list.
void	RabbitTemplate.setAfterReceivePostProcessors(MessagePostProcessor... afterReceivePostProcessors)	Set a MessagePostProcessor that will be invoked immediately after a Channel#basicGet() and before any message conversion is performed.
void	RabbitTemplate.setBeforePublishPostProcessors(MessagePostProcessor... beforePublishPostProcessors)	Set MessagePostProcessors that will be invoked immediately before invoking Channel#basicPublish(), after all other processing, except creating the AMQP.BasicProperties from MessageProperties.

Uses of MessagePostProcessor in org.springframework.amqp.rabbit.listener

Methods in org.springframework.amqp.rabbit.listener that return types with arguments of type MessagePostProcessor

Modifier and Type	Method	Description
protected Collection<MessagePostProcessor>	AbstractMessageListenerContainer.getAfterReceivePostProcessors()

Methods in org.springframework.amqp.rabbit.listener with parameters of type MessagePostProcessor

Modifier and Type	Method	Description
void	AbstractMessageListenerContainer.addAfterReceivePostProcessors(MessagePostProcessor... postprocessors)	Add MessagePostProcessors that will be applied after message reception, before invoking the MessageListener.
boolean	AbstractMessageListenerContainer.removeAfterReceivePostProcessor(MessagePostProcessor afterReceivePostProcessor)	Remove the provided MessagePostProcessor from the AbstractMessageListenerContainer.afterReceivePostProcessors list.
void	AbstractMessageListenerContainer.setAfterReceivePostProcessors(MessagePostProcessor... afterReceivePostProcessors)	Set MessagePostProcessors that will be applied after message reception, before invoking the MessageListener.

Uses of MessagePostProcessor in org.springframework.amqp.rabbit.listener.adapter

Methods in org.springframework.amqp.rabbit.listener.adapter with parameters of type MessagePostProcessor

Modifier and Type	Method	Description
void	AbstractAdaptableMessageListener.setBeforeSendReplyPostProcessors(MessagePostProcessor... beforeSendReplyPostProcessors)	Set post processors that will be applied before sending replies.

Uses of MessagePostProcessor in org.springframework.amqp.support.postprocessor

Classes in org.springframework.amqp.support.postprocessor that implement MessagePostProcessor

Modifier and Type	Class	Description
class	AbstractCompressingPostProcessor	Base class for post processors that compress the message body.
class	AbstractDecompressingPostProcessor	Base class for post processors that decompress the message body if the MessageProperties.SPRING_AUTO_DECOMPRESS header is true or to optionally always decompress if the content encoding matches AbstractDecompressingPostProcessor.getEncoding(), or starts with AbstractDecompressingPostProcessor.getEncoding() + ":", in which case the encoding following the colon becomes the final content encoding of the decompressed message.
class	AbstractDeflaterPostProcessor	Base class for post processors based on Deflater.
class	DeflaterPostProcessor	A post processor that uses a DeflaterOutputStream to compress the message body.
class	DelegatingDecompressingPostProcessor	A MessagePostProcessor that delegates to one of its MessagePostProcessors depending on the content encoding.
class	GUnzipPostProcessor	A post processor that uses a GZIPInputStream to decompress the message body.
class	GZipPostProcessor	A post processor that uses a GZIPOutputStream to compress the message body.
class	InflaterPostProcessor	A post processor that uses a InflaterInputStream to decompress the message body.
class	UnzipPostProcessor	A post processor that uses a ZipInputStream to decompress the message body.
class	ZipPostProcessor	A post processor that uses a ZipOutputStream to compress the message body.

Methods in org.springframework.amqp.support.postprocessor that return MessagePostProcessor

Modifier and Type	Method	Description
MessagePostProcessor	DelegatingDecompressingPostProcessor.removeDecompressor(String contentEncoding)	Remove the decompressor for this encoding; content will not be decompressed even if the MessageProperties.SPRING_AUTO_DECOMPRESS header is true.

Methods in org.springframework.amqp.support.postprocessor that return types with arguments of type MessagePostProcessor

Modifier and Type	Method	Description
static Collection<MessagePostProcessor>	MessagePostProcessorUtils.sort(Collection<MessagePostProcessor> processors)

Methods in org.springframework.amqp.support.postprocessor with parameters of type MessagePostProcessor

Modifier and Type	Method	Description
void	DelegatingDecompressingPostProcessor.addDecompressor(String contentEncoding, MessagePostProcessor decompressor)	Add a message post processor to the map of decompressing MessageProcessors.

Method parameters in org.springframework.amqp.support.postprocessor with type arguments of type MessagePostProcessor

Modifier and Type	Method	Description
void	DelegatingDecompressingPostProcessor.setDecompressors(Map<String,MessagePostProcessor> decompressors)	Replace all the decompressors.
static Collection<MessagePostProcessor>	MessagePostProcessorUtils.sort(Collection<MessagePostProcessor> processors)

Uses of MessagePostProcessor in org.springframework.rabbit.stream.producer

Methods in org.springframework.rabbit.stream.producer with parameters of type MessagePostProcessor

Modifier and Type	Method	Description
CompletableFuture<Boolean>	RabbitStreamOperations.convertAndSend(Object message, MessagePostProcessor mpp)	Convert to and send a Spring AMQP message.
CompletableFuture<Boolean>	RabbitStreamTemplate.convertAndSend(Object message, MessagePostProcessor mpp)