Uses of Interface
org.springframework.amqp.core.MessagePostProcessor
Packages that use MessagePostProcessor
Package
Description
Provides core classes for the spring AMQP abstraction.
Provides top-level classes for Spring Rabbit.
Provides classes supporting the Rabbit XML namespace.
Provides core classes for Spring Rabbit.
Provides classes for message listener containers.
Provides classes for adapting listeners.
Package for Spring AMQP message post processors.
Provides classes for stream producers.
-
Uses of MessagePostProcessor in org.springframework.amqp.core
Methods in org.springframework.amqp.core with parameters of type MessagePostProcessorModifier and TypeMethodDescriptionvoidAmqpTemplate.convertAndSend(Object message, MessagePostProcessor messagePostProcessor) Convert a Java object to an AmqpMessageand send it to a default exchange with a default routing key.voidAmqpTemplate.convertAndSend(String routingKey, Object message, MessagePostProcessor messagePostProcessor) Convert a Java object to an AmqpMessageand send it to a default exchange with a specific routing key.voidAmqpTemplate.convertAndSend(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor) Convert a Java object to an AmqpMessageand send it to a specific exchange with a specific routing key.AmqpTemplate.convertSendAndReceive(Object message, MessagePostProcessor messagePostProcessor) Basic RPC pattern with conversion.AmqpTemplate.convertSendAndReceive(String routingKey, Object message, MessagePostProcessor messagePostProcessor) Basic RPC pattern with conversion.AmqpTemplate.convertSendAndReceive(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor) Basic RPC pattern with conversion.<C> ListenableFuture<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 theMessagePostProcessor.<C> ListenableFuture<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 theMessagePostProcessor.<C> ListenableFuture<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 theMessagePostProcessor.<T> TAmqpTemplate.convertSendAndReceiveAsType(Object message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType) Basic RPC pattern with conversion.<T> TAmqpTemplate.convertSendAndReceiveAsType(String routingKey, Object message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType) Basic RPC pattern with conversion.<T> TAmqpTemplate.convertSendAndReceiveAsType(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType) Basic RPC pattern with conversion.<C> ListenableFuture<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 theMessagePostProcessor.<C> ListenableFuture<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 theMessagePostProcessor.<C> ListenableFuture<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 theMessagePostProcessor. -
Uses of MessagePostProcessor in org.springframework.amqp.rabbit
Methods in org.springframework.amqp.rabbit with parameters of type MessagePostProcessorModifier and TypeMethodDescriptionAsyncRabbitTemplate.convertSendAndReceive(Object object, MessagePostProcessor messagePostProcessor) AsyncRabbitTemplate.convertSendAndReceive(String routingKey, Object object, MessagePostProcessor messagePostProcessor) AsyncRabbitTemplate.convertSendAndReceive(String exchange, String routingKey, Object object, MessagePostProcessor messagePostProcessor) AsyncRabbitTemplate.convertSendAndReceiveAsType(Object object, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<C> responseType) AsyncRabbitTemplate.convertSendAndReceiveAsType(String routingKey, Object object, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<C> responseType) 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 MessagePostProcessorModifier and TypeMethodDescriptionvoidAbstractRabbitListenerContainerFactory.setAfterReceivePostProcessors(MessagePostProcessor... postProcessors) Set post processors which will be applied after the Message is received.voidListenerContainerFactoryBean.setAfterReceivePostProcessors(MessagePostProcessor... afterReceivePostProcessors) voidBaseRabbitListenerContainerFactory.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 MessagePostProcessorModifier and TypeMethodDescriptionRabbitTemplate.getAfterReceivePostProcessors()Return configured after receiveMessagePostProcessors ornull.Methods in org.springframework.amqp.rabbit.core with parameters of type MessagePostProcessorModifier and TypeMethodDescriptionvoidRabbitTemplate.addAfterReceivePostProcessors(MessagePostProcessor... afterReceivePostProcessors) AddMessagePostProcessorthat will be invoked immediately after aChannel#basicGet()and before any message conversion is performed.voidRabbitTemplate.addBeforePublishPostProcessors(MessagePostProcessor... beforePublishPostProcessors) AddMessagePostProcessorthat will be invoked immediately before invokingChannel#basicPublish(), after all other processing, except creating theAMQP.BasicPropertiesfromMessageProperties.voidRabbitOperations.convertAndSend(Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) Convert a Java object to an AmqpMessageand send it to a default exchange with a default routing key.voidRabbitOperations.convertAndSend(String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) Convert a Java object to an AmqpMessageand send it to a default exchange with a specific routing key.voidRabbitOperations.convertAndSend(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) Convert a Java object to an AmqpMessageand send it to a specific exchange with a specific routing key.voidRabbitTemplate.convertAndSend(Object message, MessagePostProcessor messagePostProcessor) voidRabbitTemplate.convertAndSend(Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) voidRabbitTemplate.convertAndSend(String routingKey, Object message, MessagePostProcessor messagePostProcessor) voidRabbitTemplate.convertAndSend(String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) voidRabbitTemplate.convertAndSend(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor) voidRabbitTemplate.convertAndSend(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) RabbitOperations.convertSendAndReceive(Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) Basic RPC pattern with conversion.RabbitOperations.convertSendAndReceive(String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) Basic RPC pattern with conversion.RabbitOperations.convertSendAndReceive(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) Basic RPC pattern with conversion.RabbitTemplate.convertSendAndReceive(Object message, MessagePostProcessor messagePostProcessor) RabbitTemplate.convertSendAndReceive(Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) RabbitTemplate.convertSendAndReceive(String routingKey, Object message, MessagePostProcessor messagePostProcessor) RabbitTemplate.convertSendAndReceive(String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) RabbitTemplate.convertSendAndReceive(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor) RabbitTemplate.convertSendAndReceive(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) <T> TRabbitOperations.convertSendAndReceiveAsType(Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) Basic RPC pattern with conversion.<T> TRabbitOperations.convertSendAndReceiveAsType(String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) Basic RPC pattern with conversion.<T> TRabbitOperations.convertSendAndReceiveAsType(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) Basic RPC pattern with conversion.<T> TRabbitTemplate.convertSendAndReceiveAsType(Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) <T> TRabbitTemplate.convertSendAndReceiveAsType(Object message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType) <T> TRabbitTemplate.convertSendAndReceiveAsType(String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) <T> TRabbitTemplate.convertSendAndReceiveAsType(String routingKey, Object message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType) <T> TRabbitTemplate.convertSendAndReceiveAsType(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) <T> TRabbitTemplate.convertSendAndReceiveAsType(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType) protected MessageRabbitTemplate.convertSendAndReceiveRaw(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) Convert and send a message and return the raw reply message, or null.booleanRabbitTemplate.removeAfterReceivePostProcessor(MessagePostProcessor afterReceivePostProcessor) Remove the providedMessagePostProcessorfrom theRabbitTemplate.afterReceivePostProcessorslist.booleanRabbitTemplate.removeBeforePublishPostProcessor(MessagePostProcessor beforePublishPostProcessor) Remove the providedMessagePostProcessorfrom theRabbitTemplate.beforePublishPostProcessorslist.voidRabbitTemplate.setAfterReceivePostProcessors(MessagePostProcessor... afterReceivePostProcessors) Set aMessagePostProcessorthat will be invoked immediately after aChannel#basicGet()and before any message conversion is performed.voidRabbitTemplate.setBeforePublishPostProcessors(MessagePostProcessor... beforePublishPostProcessors) SetMessagePostProcessors that will be invoked immediately before invokingChannel#basicPublish(), after all other processing, except creating theAMQP.BasicPropertiesfromMessageProperties. -
Uses of MessagePostProcessor in org.springframework.amqp.rabbit.listener
Methods in org.springframework.amqp.rabbit.listener that return types with arguments of type MessagePostProcessorModifier and TypeMethodDescriptionprotected Collection<MessagePostProcessor>AbstractMessageListenerContainer.getAfterReceivePostProcessors()Methods in org.springframework.amqp.rabbit.listener with parameters of type MessagePostProcessorModifier and TypeMethodDescriptionvoidAbstractMessageListenerContainer.addAfterReceivePostProcessors(MessagePostProcessor... postprocessors) AddMessagePostProcessors that will be applied after message reception, before invoking theMessageListener.booleanAbstractMessageListenerContainer.removeAfterReceivePostProcessor(MessagePostProcessor afterReceivePostProcessor) Remove the providedMessagePostProcessorfrom theAbstractMessageListenerContainer.afterReceivePostProcessorslist.voidAbstractMessageListenerContainer.setAfterReceivePostProcessors(MessagePostProcessor... afterReceivePostProcessors) SetMessagePostProcessors that will be applied after message reception, before invoking theMessageListener. -
Uses of MessagePostProcessor in org.springframework.amqp.rabbit.listener.adapter
Methods in org.springframework.amqp.rabbit.listener.adapter with parameters of type MessagePostProcessorModifier and TypeMethodDescriptionvoidAbstractAdaptableMessageListener.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 MessagePostProcessorModifier and TypeClassDescriptionclassBase class for post processors that compress the message body.classBase class for post processors that decompress the message body if theMessageProperties.SPRING_AUTO_DECOMPRESSheader is true or to optionally always decompress if the content encoding matchesAbstractDecompressingPostProcessor.getEncoding(), or starts withAbstractDecompressingPostProcessor.getEncoding()+ ":", in which case the encoding following the colon becomes the final content encoding of the decompressed message.classBase class for post processors based onDeflater.classA post processor that uses aDeflaterOutputStreamto compress the message body.classAMessagePostProcessorthat delegates to one of itsMessagePostProcessors depending on the content encoding.classA post processor that uses aGZIPInputStreamto decompress the message body.classA post processor that uses aGZIPOutputStreamto compress the message body.classA post processor that uses aInflaterInputStreamto decompress the message body.classA post processor that uses aZipInputStreamto decompress the message body.classA post processor that uses aZipOutputStreamto compress the message body.Methods in org.springframework.amqp.support.postprocessor that return MessagePostProcessorModifier and TypeMethodDescriptionDelegatingDecompressingPostProcessor.removeDecompressor(String contentEncoding) Remove the decompressor for this encoding; content will not be decompressed even if theMessageProperties.SPRING_AUTO_DECOMPRESSheader is true.Methods in org.springframework.amqp.support.postprocessor that return types with arguments of type MessagePostProcessorModifier and TypeMethodDescriptionstatic Collection<MessagePostProcessor>MessagePostProcessorUtils.sort(Collection<MessagePostProcessor> processors) Methods in org.springframework.amqp.support.postprocessor with parameters of type MessagePostProcessorModifier and TypeMethodDescriptionvoidDelegatingDecompressingPostProcessor.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 MessagePostProcessorModifier and TypeMethodDescriptionvoidDelegatingDecompressingPostProcessor.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 MessagePostProcessorModifier and TypeMethodDescriptionRabbitStreamOperations.convertAndSend(Object message, MessagePostProcessor mpp) Convert to and send a Spring AMQP message.RabbitStreamTemplate.convertAndSend(Object message, MessagePostProcessor mpp)