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.rabbitmq.client	Provides Spring support for RabbitMQ AMQP 1.0 Client.
org.springframework.amqp.rabbitmq.client.config	Provides classes for Spring application context support.
org.springframework.amqp.rabbitmq.client.listener	Provides Spring support for RabbitMQ AMQP 1.0 Consumer.
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(@Nullable String exchange, @Nullable 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.
void	AmqpTemplate.convertAndSend(@Nullable 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(Object message, MessagePostProcessor messagePostProcessor)	Convert a Java object to an Amqp Message and send it to a default exchange with a default routing key.
default CompletableFuture<Boolean>	AsyncAmqpTemplate.convertAndSend(Object message, @Nullable MessagePostProcessor messagePostProcessor)
default CompletableFuture<Boolean>	AsyncAmqpTemplate.convertAndSend(String exchange, @Nullable String routingKey, Object message, @Nullable MessagePostProcessor messagePostProcessor)
default CompletableFuture<Boolean>	AsyncAmqpTemplate.convertAndSend(String queue, Object message, @Nullable MessagePostProcessor messagePostProcessor)
@Nullable Object	AmqpTemplate.convertSendAndReceive(Object message, MessagePostProcessor messagePostProcessor)	Basic RPC pattern with conversion.
@Nullable Object	AmqpTemplate.convertSendAndReceive(String routingKey, Object message, MessagePostProcessor messagePostProcessor)	Basic RPC pattern with conversion.
@Nullable 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 exchange, @Nullable String routingKey, Object object, @Nullable MessagePostProcessor messagePostProcessor)	Convert the object to a message and send it to the provided exchange and 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.
<T> @Nullable T	AmqpTemplate.convertSendAndReceiveAsType(Object message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType)	Basic RPC pattern with conversion.
<T> @Nullable T	AmqpTemplate.convertSendAndReceiveAsType(String routingKey, Object message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType)	Basic RPC pattern with conversion.
<T> @Nullable 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, @Nullable MessagePostProcessor messagePostProcessor, @Nullable 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 exchange, @Nullable String routingKey, Object object, @Nullable MessagePostProcessor messagePostProcessor, @Nullable ParameterizedTypeReference<C> responseType)	Convert the object to a message and send it to the provided exchange and routing key after invoking the MessagePostProcessor.
<C> CompletableFuture<C>	AsyncAmqpTemplate.convertSendAndReceiveAsType(String routingKey, Object object, @Nullable MessagePostProcessor messagePostProcessor, @Nullable 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.

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(@Nullable String exchange, @Nullable String routingKey, Object object, @Nullable MessagePostProcessor messagePostProcessor)
<C> RabbitConverterFuture<C>	AsyncRabbitTemplate.convertSendAndReceive(@Nullable String routingKey, Object object, MessagePostProcessor messagePostProcessor)
<C> RabbitConverterFuture<C>	AsyncRabbitTemplate.convertSendAndReceive(Object object, MessagePostProcessor messagePostProcessor)
<C> RabbitConverterFuture<C>	AsyncRabbitTemplate.convertSendAndReceiveAsType(@Nullable String exchange, @Nullable String routingKey, Object object, @Nullable MessagePostProcessor messagePostProcessor, @Nullable ParameterizedTypeReference<C> responseType)
<C> RabbitConverterFuture<C>	AsyncRabbitTemplate.convertSendAndReceiveAsType(@Nullable String routingKey, Object object, @Nullable MessagePostProcessor messagePostProcessor, @Nullable ParameterizedTypeReference<C> responseType)
<C> RabbitConverterFuture<C>	AsyncRabbitTemplate.convertSendAndReceiveAsType(Object object, @Nullable MessagePostProcessor messagePostProcessor, @Nullable 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
@Nullable Collection<MessagePostProcessor>	RabbitTemplate.getAfterReceivePostProcessors()	Return configured after receive MessagePostProcessors or null.
@Nullable Collection<MessagePostProcessor>	RabbitTemplate.getBeforePublishPostProcessors()	Return configured before post 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(@Nullable String exchange, @Nullable String routingKey, Object message, MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData)	Convert a Java object to an Amqp Message and send it to a specific exchange with a specific routing key.
void	RabbitOperations.convertAndSend(@Nullable String routingKey, Object message, MessagePostProcessor messagePostProcessor, @Nullable 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(Object message, MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData)	Convert a Java object to an Amqp Message and send it to a default exchange with a default routing key.
void	RabbitTemplate.convertAndSend(@Nullable String exchange, @Nullable String routingKey, Object message, MessagePostProcessor messagePostProcessor)
void	RabbitTemplate.convertAndSend(@Nullable String exchange, @Nullable String routingKey, Object message, MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData)
void	RabbitTemplate.convertAndSend(@Nullable String routingKey, Object message, MessagePostProcessor messagePostProcessor)
void	RabbitTemplate.convertAndSend(@Nullable String routingKey, Object message, MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData)
void	RabbitTemplate.convertAndSend(Object message, MessagePostProcessor messagePostProcessor)
void	RabbitTemplate.convertAndSend(Object message, MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData)
@Nullable Object	RabbitOperations.convertSendAndReceive(@Nullable String exchange, @Nullable String routingKey, Object message, @Nullable MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData)	Basic RPC pattern with conversion.
@Nullable Object	RabbitOperations.convertSendAndReceive(@Nullable String routingKey, Object message, MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData)	Basic RPC pattern with conversion.
@Nullable Object	RabbitOperations.convertSendAndReceive(Object message, MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData)	Basic RPC pattern with conversion.
@Nullable Object	RabbitTemplate.convertSendAndReceive(@Nullable String exchange, @Nullable String routingKey, Object message, @Nullable MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData)
@Nullable Object	RabbitTemplate.convertSendAndReceive(@Nullable String exchange, @Nullable String routingKey, Object message, MessagePostProcessor messagePostProcessor)
@Nullable Object	RabbitTemplate.convertSendAndReceive(@Nullable String routingKey, Object message, MessagePostProcessor messagePostProcessor)
@Nullable Object	RabbitTemplate.convertSendAndReceive(@Nullable String routingKey, Object message, MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData)
@Nullable Object	RabbitTemplate.convertSendAndReceive(Object message, MessagePostProcessor messagePostProcessor)
@Nullable Object	RabbitTemplate.convertSendAndReceive(Object message, MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData)
<T> @Nullable T	RabbitOperations.convertSendAndReceiveAsType(@Nullable String exchange, @Nullable String routingKey, Object message, @Nullable MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData, ParameterizedTypeReference<T> responseType)	Basic RPC pattern with conversion.
<T> @Nullable T	RabbitOperations.convertSendAndReceiveAsType(@Nullable String routingKey, Object message, @Nullable MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData, ParameterizedTypeReference<T> responseType)	Basic RPC pattern with conversion.
<T> @Nullable T	RabbitOperations.convertSendAndReceiveAsType(Object message, @Nullable MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData, ParameterizedTypeReference<T> responseType)	Basic RPC pattern with conversion.
<T> @Nullable T	RabbitTemplate.convertSendAndReceiveAsType(@Nullable String exchange, @Nullable String routingKey, Object message, @Nullable MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData, ParameterizedTypeReference<T> responseType)
<T> @Nullable T	RabbitTemplate.convertSendAndReceiveAsType(@Nullable String routingKey, Object message, @Nullable MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData, ParameterizedTypeReference<T> responseType)
<T> @Nullable T	RabbitTemplate.convertSendAndReceiveAsType(@Nullable String routingKey, Object message, @Nullable MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType)
<T> @Nullable T	RabbitTemplate.convertSendAndReceiveAsType(Object message, @Nullable MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData, ParameterizedTypeReference<T> responseType)
<T> @Nullable T	RabbitTemplate.convertSendAndReceiveAsType(Object message, @Nullable MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType)
<T> @Nullable T	RabbitTemplate.convertSendAndReceiveAsType(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType)
protected @Nullable Message	RabbitTemplate.convertSendAndReceiveRaw(@Nullable String exchange, @Nullable String routingKey, Object message, @Nullable MessagePostProcessor messagePostProcessor, @Nullable 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 @Nullable 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 that return MessagePostProcessor

Modifier and Type	Method	Description
MessagePostProcessor @Nullable []	AbstractAdaptableMessageListener.getBeforeSendReplyPostProcessors()

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.rabbitmq.client

Methods in org.springframework.amqp.rabbitmq.client with parameters of type MessagePostProcessor

Modifier and Type	Method	Description
CompletableFuture<Boolean>	RabbitAmqpTemplate.convertAndSend(Object message, @Nullable MessagePostProcessor messagePostProcessor)
CompletableFuture<Boolean>	RabbitAmqpTemplate.convertAndSend(String exchange, @Nullable String routingKey, Object message, @Nullable MessagePostProcessor messagePostProcessor)
CompletableFuture<Boolean>	RabbitAmqpTemplate.convertAndSend(String queue, Object message, @Nullable MessagePostProcessor messagePostProcessor)
<C> CompletableFuture<C>	RabbitAmqpTemplate.convertSendAndReceive(Object object, MessagePostProcessor messagePostProcessor)
<C> CompletableFuture<C>	RabbitAmqpTemplate.convertSendAndReceive(String exchange, @Nullable String routingKey, Object object, @Nullable MessagePostProcessor messagePostProcessor)
<C> CompletableFuture<C>	RabbitAmqpTemplate.convertSendAndReceive(String queue, Object object, MessagePostProcessor messagePostProcessor)
<C> CompletableFuture<C>	RabbitAmqpTemplate.convertSendAndReceiveAsType(Object object, @Nullable MessagePostProcessor messagePostProcessor, @Nullable ParameterizedTypeReference<C> responseType)
<C> CompletableFuture<C>	RabbitAmqpTemplate.convertSendAndReceiveAsType(String exchange, @Nullable String routingKey, Object object, @Nullable MessagePostProcessor messagePostProcessor, @Nullable ParameterizedTypeReference<C> responseType)
<C> CompletableFuture<C>	RabbitAmqpTemplate.convertSendAndReceiveAsType(String queue, Object object, @Nullable MessagePostProcessor messagePostProcessor, @Nullable ParameterizedTypeReference<C> responseType)

Uses of MessagePostProcessor in org.springframework.amqp.rabbitmq.client.config

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

Modifier and Type	Method	Description
void	RabbitAmqpListenerContainerFactory.setAfterReceivePostProcessors(MessagePostProcessor... afterReceivePostProcessors)	Set MessagePostProcessors that will be applied after message reception, before invoking the MessageListener.

Uses of MessagePostProcessor in org.springframework.amqp.rabbitmq.client.listener

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

Modifier and Type	Method	Description
void	RabbitAmqpListenerContainer.setAfterReceivePostProcessors(MessagePostProcessor... afterReceivePostProcessors)	Set MessagePostProcessors that will be applied after message reception, before invoking the MessageListener.

Method parameters in org.springframework.amqp.rabbitmq.client.listener with type arguments of type MessagePostProcessor

Modifier and Type	Method	Description
void	RabbitAmqpMessageListenerAdapter.setAfterReceivePostProcessors(Collection<MessagePostProcessor> afterReceivePostProcessors)

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, @Nullable MessagePostProcessor mpp)	Convert to and send a Spring AMQP message.
CompletableFuture<Boolean>	RabbitStreamTemplate.convertAndSend(Object message, @Nullable MessagePostProcessor mpp)