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