Index

A B C D E F G H I J K L M N O P Q R S T U V W X Z _
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

P

parseBinding(String, Element, ParserContext) - Method in class org.springframework.amqp.rabbit.config.AbstractExchangeParser

parseBinding(String, Element, ParserContext) - Method in class org.springframework.amqp.rabbit.config.DirectExchangeParser

parseBinding(String, Element, ParserContext) - Method in class org.springframework.amqp.rabbit.config.FanoutExchangeParser

parseBinding(String, Element, ParserContext) - Method in class org.springframework.amqp.rabbit.config.HeadersExchangeParser

parseBinding(String, Element, ParserContext) - Method in class org.springframework.amqp.rabbit.config.TopicExchangeParser

parseBindings(Element, ParserContext, BeanDefinitionBuilder, String) - Method in class org.springframework.amqp.rabbit.config.AbstractExchangeParser

parseBooleanProperty(String) - Static method in class org.springframework.amqp.rabbit.junit.JUnitUtils

Return the parsed value if the provided property exists in the environment or system properties.

parseContainer(Element, ParserContext) - Static method in class org.springframework.amqp.rabbit.config.RabbitNamespaceUtils

parseDeclarationControls(Element, BeanDefinitionBuilder) - Static method in class org.springframework.amqp.rabbit.config.NamespaceUtils

Parses 'auto-declare' and 'declared-by' attributes.

parseDestination(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.amqp.rabbit.config.AbstractExchangeParser

password() - Element in annotation interface org.springframework.amqp.rabbit.test.context.SpringRabbitTest

Set the password when not using RabbitAvailable.

PendingConfirm - Class in org.springframework.amqp.rabbit.connection

Instances of this object track pending publisher confirms.

PendingConfirm(CorrelationData, long) - Constructor for class org.springframework.amqp.rabbit.connection.PendingConfirm

PERSISTENT - Enum constant in enum class org.springframework.amqp.core.MessageDeliveryMode

Persistent.

PooledChannelConnectionFactory - Class in org.springframework.amqp.rabbit.connection

A very simple connection factory that caches channels using Apache Pool2 GenericObjectPools (one for transactional and one for non-transactional channels).

PooledChannelConnectionFactory(ConnectionFactory) - Constructor for class org.springframework.amqp.rabbit.connection.PooledChannelConnectionFactory

Construct an instance.

pop(Object) - Static method in class org.springframework.amqp.rabbit.connection.SimpleResourceHolder

Unbind the current value and bind the head of the stack if present.

port() - Element in annotation interface org.springframework.amqp.rabbit.test.context.SpringRabbitTest

Set the port when not using RabbitAvailable.

postProcess(Message, CorrelationData) - Method in interface org.springframework.amqp.rabbit.core.CorrelationDataPostProcessor

Update or replace the correlation data provided in the send method.

postProcessAfterInitialization(Object, String) - Method in class org.springframework.amqp.rabbit.annotation.RabbitListenerAnnotationBeanPostProcessor

postProcessBeforeInitialization(Object, String) - Method in class org.springframework.amqp.rabbit.annotation.RabbitListenerAnnotationBeanPostProcessor

postProcessChannel(Channel, Message) - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener

Post-process the given message before sending the response.

postProcessMessage(Message) - Method in interface org.springframework.amqp.core.MessagePostProcessor

Change (or replace) the message.

postProcessMessage(Message) - Method in class org.springframework.amqp.support.postprocessor.AbstractCompressingPostProcessor

postProcessMessage(Message) - Method in class org.springframework.amqp.support.postprocessor.AbstractDecompressingPostProcessor

postProcessMessage(Message) - Method in class org.springframework.amqp.support.postprocessor.DelegatingDecompressingPostProcessor

postProcessMessage(Message, Correlation) - Method in interface org.springframework.amqp.core.MessagePostProcessor

Change (or replace) the message and/or change its correlation data.

postProcessMessage(Message, Correlation, String, String) - Method in interface org.springframework.amqp.core.MessagePostProcessor

Change (or replace) the message and/or change its correlation data.

postProcessMessageBeforeSend(Message, AmqpAppender.Event) - Method in class org.springframework.amqp.rabbit.log4j2.AmqpAppender

Subclasses may modify the final message before sending.

postProcessMessageBeforeSend(Message, AmqpAppender.Event) - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender

Subclasses may modify the final message before sending.

postProcessResponse(Message, Message) - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener

Post-process the given response message before it will be sent.

PREFIX - Static variable in class org.springframework.amqp.support.AmqpHeaders

Prefix used for AMQP related headers in order to distinguish from user-defined headers and other internal headers (e.g.

prepareHolderForRollback(RabbitResourceHolder, RuntimeException) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer

A null resource holder is rare, but possible if the transaction attribute caused no transaction to be started (e.g.

prepareMessageProperties(AmqpAppender.Event) - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender

prepareSwitchContext() - Method in class org.springframework.amqp.rabbit.connection.ThreadChannelConnectionFactory

Call to prepare to switch the channel(s) owned by this thread to another thread.

priority() - Element in annotation interface org.springframework.amqp.rabbit.annotation.RabbitListener

The priority of this endpoint.

PRIORITY - Static variable in class org.springframework.amqp.support.AmqpMessageHeaderAccessor

processAmqpListener(RabbitListener, Method, Object, String) - Method in class org.springframework.amqp.rabbit.annotation.MultiRabbitListenerAnnotationBeanPostProcessor

processAmqpListener(RabbitListener, Method, Object, String) - Method in class org.springframework.amqp.rabbit.annotation.RabbitListenerAnnotationBeanPostProcessor

processListener(MethodRabbitListenerEndpoint, RabbitListener, Object, Object, String) - Method in class org.springframework.amqp.rabbit.annotation.RabbitListenerAnnotationBeanPostProcessor

processListener(MethodRabbitListenerEndpoint, RabbitListener, Object, Object, String) - Method in class org.springframework.amqp.rabbit.test.RabbitListenerTestHarness

processMonitorTask() - Method in class org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer

Subclasses can override this to take additional actions when the monitor task runs.

processMonitorTask() - Method in class org.springframework.amqp.rabbit.listener.DirectReplyToMessageListenerContainer

ProducerCustomizer - Interface in org.springframework.rabbit.stream.producer

Called to enable customization of the ProducerBuilder when a new producer is created.

ProjectingMessageConverter - Class in org.springframework.amqp.support.converter

Uses a Spring Data ProjectionFactory to bind incoming messages to projection interfaces.

ProjectingMessageConverter(ObjectMapper) - Constructor for class org.springframework.amqp.support.converter.ProjectingMessageConverter

PUBLISH_CONFIRM - Static variable in class org.springframework.amqp.support.AmqpHeaders

PUBLISH_CONFIRM_CORRELATION - Static variable in class org.springframework.amqp.support.AmqpHeaders

A CorrelationData instance for publisher confirms (not mapped).

PUBLISH_CONFIRM_NACK_CAUSE - Static variable in class org.springframework.amqp.support.AmqpHeaders

publishConsumerFailedEvent(String, boolean, Throwable) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer

publishConsumerFailedEvent(String, boolean, Throwable) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer

PublisherCallbackChannel - Interface in org.springframework.amqp.rabbit.connection

Instances of this interface support a single listener being registered for publisher confirms with multiple channels, by adding context to the callbacks.

PublisherCallbackChannel.Listener - Interface in org.springframework.amqp.rabbit.connection

Listeners implementing this interface can participate in publisher confirms received from multiple channels, by invoking addListener on each channel.

PublisherCallbackChannelFactory - Interface in org.springframework.amqp.rabbit.connection

A factory for PublisherCallbackChannels.

PublisherCallbackChannelImpl - Class in org.springframework.amqp.rabbit.connection

Channel wrapper to allow a single listener able to handle confirms from multiple channels.

PublisherCallbackChannelImpl(Channel, ExecutorService) - Constructor for class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl

Create a PublisherCallbackChannelImpl instance based on the provided delegate and executor.

publishIdleContainerEvent(long) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer

publishMissingQueueEvent(String) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer

purgeAfterEach() - Element in annotation interface org.springframework.amqp.rabbit.junit.RabbitAvailable

Purge the test queues after each test.

purgeQueue(String) - Method in interface org.springframework.amqp.core.AmqpAdmin

Purges the contents of the given queue.

purgeQueue(String) - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin

purgeQueue(String, boolean) - Method in interface org.springframework.amqp.core.AmqpAdmin

Purges the contents of the given queue.

purgeQueue(String, boolean) - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin

purgeTestQueues() - Method in class org.springframework.amqp.rabbit.junit.BrokerRunning

Delete and re-declare all the configured queues.

purgeTestQueues() - Method in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport

Delete and re-declare all the configured queues.

push(Object, Object) - Static method in class org.springframework.amqp.rabbit.connection.SimpleResourceHolder

Set the value for this key and push any existing value onto a stack.

put(K, V) - Method in class org.springframework.amqp.utils.MapBuilder

A B C D E F G H I J K L M N O P Q R S T U V W X Z _
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form