A B C D E F G H I L M N O P Q R S T V W

A

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

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

Create a new SingleConnectionFactory for the given target ConnectionFactory.

AbstractExchangeParser - Class in org.springframework.amqp.rabbit.config

AbstractExchangeParser() - Constructor for class org.springframework.amqp.rabbit.config.AbstractExchangeParser

AbstractMessageListenerContainer - Class in org.springframework.amqp.rabbit.listener

AbstractMessageListenerContainer() - Constructor for class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer

AbstractMessageListenerContainer.SharedConnectionNotInitializedException - Exception in org.springframework.amqp.rabbit.listener

Exception that indicates that the initial setup of this container's shared Rabbit Connection failed.

AbstractMessageListenerContainer.SharedConnectionNotInitializedException(String) - Constructor for exception org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.SharedConnectionNotInitializedException

Create a new SharedConnectionNotInitializedException.

AbstractRetryOperationsInterceptorFactoryBean - Class in org.springframework.amqp.rabbit.config

Convenient base class for interceptor factories.

AbstractRetryOperationsInterceptorFactoryBean() - Constructor for class org.springframework.amqp.rabbit.config.AbstractRetryOperationsInterceptorFactoryBean

ActiveObjectCounter<T> - Class in org.springframework.amqp.rabbit.listener

ActiveObjectCounter() - Constructor for class org.springframework.amqp.rabbit.listener.ActiveObjectCounter

add(T) - Method in class org.springframework.amqp.rabbit.listener.ActiveObjectCounter

addChannel(Channel) - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder

addChannel(Channel, Connection) - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder

addChannelListener(ChannelListener) - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory

addConnection(Connection) - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder

addConnectionListener(ConnectionListener) - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory

addConnectionListener(ConnectionListener) - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory

addConnectionListener(ConnectionListener) - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactory

addConnectionListener(ConnectionListener) - Method in class org.springframework.amqp.rabbit.connection.SingleConnectionFactory

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

Populates the bean definition constructor argument with the boolean value of that attribute if it is defined in the given element or else uses the default provided.

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

Populates the bean definition constructor argument with a reference to a bean with parent id equal to the attribute if it is defined in the given element.

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

Populates the bean definition constructor argument with a reference to a bean with id equal to the attribute if it is defined in the given element.

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

Populates the bean definition constructor argument with the value of that attribute if it is defined in the given element.

addDelegate(ChannelListener) - Method in class org.springframework.amqp.rabbit.connection.CompositeChannelListener

addDelegate(ConnectionListener) - Method in class org.springframework.amqp.rabbit.connection.CompositeConnectionListener

addDeliveryTag(Channel, long) - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder

afterPropertiesSet() - Method in class org.springframework.amqp.rabbit.connection.RabbitAccessor

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

If autoStartup is set to true, registers a callback on the ConnectionFactory to declare all exchanges and queues in the enclosing application context.

afterPropertiesSet() - Method in class org.springframework.amqp.rabbit.core.support.RabbitGatewaySupport

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

Delegates to AbstractMessageListenerContainer.validateConfiguration() and AbstractMessageListenerContainer.initialize().

afterPropertiesSet() - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager

Make sure the ConnectionFactory has been set.

AmqpAppender - Class in org.springframework.amqp.rabbit.log4j

A Log4J appender that publishes logging events to an AMQP Exchange.

AmqpAppender() - Constructor for class org.springframework.amqp.rabbit.log4j.AmqpAppender

AmqpAppender.Event - Class in org.springframework.amqp.rabbit.log4j

Small helper class to encapsulate a LoggingEvent, its MDC properties, and the number of retries.

AmqpAppender.Event(LoggingEvent, Map) - Constructor for class org.springframework.amqp.rabbit.log4j.AmqpAppender.Event

AmqpAppender.EventSender - Class in org.springframework.amqp.rabbit.log4j

Helper class to actually send LoggingEvents asynchronously.

AmqpAppender.EventSender() - Constructor for class org.springframework.amqp.rabbit.log4j.AmqpAppender.EventSender

append(LoggingEvent) - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender

APPLICATION_ID - Static variable in class org.springframework.amqp.rabbit.log4j.AmqpAppender

Key name for the application id (if there is one set via the appender config) in the message properties.

await(Long, TimeUnit) - Method in class org.springframework.amqp.rabbit.listener.ActiveObjectCounter

B

BINDING_QUEUE_ATTR - Static variable in class org.springframework.amqp.rabbit.config.AbstractExchangeParser

BindingFactoryBean - Class in org.springframework.amqp.rabbit.config

BindingFactoryBean() - Constructor for class org.springframework.amqp.rabbit.config.BindingFactoryBean

bindResourceToTransaction(RabbitResourceHolder, ConnectionFactory, boolean) - Static method in class org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils

BlockingQueueConsumer - Class in org.springframework.amqp.rabbit.listener

Specialized consumer encapsulating knowledge of the broker connections and having its own lifecycle (start and stop).

BlockingQueueConsumer(ConnectionFactory, MessagePropertiesConverter, ActiveObjectCounter<BlockingQueueConsumer>, AcknowledgeMode, boolean, int, String...) - Constructor for class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer

Create a consumer.

buildListenerArguments(Object) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter

Build an array of arguments to be passed into the target listener method.

buildMessage(Channel, Object) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter

Build a Rabbit message to be sent as response based on the given result object.

C

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

A ConnectionFactory implementation that returns the same Connections from all CachingConnectionFactory.createConnection() calls, and ignores calls to Connection.close() and caches Channel.

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

Create a new CachingConnectionFactory initializing the hostname to be the value returned from InetAddress.getLocalHost(), or "localhost" if getLocalHost() throws an exception.

CachingConnectionFactory(String, int) - Constructor for class org.springframework.amqp.rabbit.connection.CachingConnectionFactory

Create a new CachingConnectionFactory given a host name.

CachingConnectionFactory(int) - Constructor for class org.springframework.amqp.rabbit.connection.CachingConnectionFactory

Create a new CachingConnectionFactory given a host name.

CachingConnectionFactory(String) - Constructor for class org.springframework.amqp.rabbit.connection.CachingConnectionFactory

Create a new CachingConnectionFactory given a host name.

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

Create a new CachingConnectionFactory for the given target ConnectionFactory.

CATEGORY_LEVEL - Static variable in class org.springframework.amqp.rabbit.log4j.AmqpAppender

Key name for the logger level name in the message properties

CATEGORY_NAME - Static variable in class org.springframework.amqp.rabbit.log4j.AmqpAppender

Key name for the logger category name in the message properties

ChannelAwareMessageListener - Interface in org.springframework.amqp.rabbit.core

A message listener that is aware of the Channel on which the message was received.

ChannelCallback<T> - Interface in org.springframework.amqp.rabbit.core

Basic callback for use in RabbitTemplate

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

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

Subinterface of Channel to be implemented by Channel proxies.

checkMessageListener(Object) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer

Check the given message listener, throwing an exception if it does not correspond to a supported listener type.

close() - Method in interface org.springframework.amqp.rabbit.connection.Connection

Close this connection and all its channels with the AMQP.REPLY_SUCCESS close code and message 'OK'.

close() - Method in class org.springframework.amqp.rabbit.connection.SimpleConnection

close() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender

closeAll() - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder

closeChannel(Channel) - Static method in class org.springframework.amqp.rabbit.connection.RabbitUtils

Close the given RabbitMQ Channel and ignore any thrown exception.

closeConnection(Connection) - Static method in class org.springframework.amqp.rabbit.connection.RabbitUtils

Close the given RabbitMQ Connection and ignore any thrown exception.

closeMessageConsumer(Channel, String, boolean) - Static method in class org.springframework.amqp.rabbit.connection.RabbitUtils

commitAll() - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder

commitIfNecessary(Channel) - Static method in class org.springframework.amqp.rabbit.connection.RabbitUtils

Commit the Channel if not within a JTA transaction.

commitIfNecessary(boolean) - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer

Perform a commit or message acknowledgement, as appropriate.

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

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

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

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

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

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

An interface based ConnectionFactory for creating Connections.

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

Helper class for managing a Spring based Rabbit ConnectionFactory, in particular for obtaining transactional Rabbit resources for a given ConnectionFactory.

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

ConnectionFactoryUtils.ResourceFactory - Interface in org.springframework.amqp.rabbit.connection

Callback interface for resource creation.

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

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

Subinterface of Connection to be implemented by Connection proxies.

containsChannel(Channel) - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder

convertAndSend(Object) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate

convertAndSend(String, Object) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate

convertAndSend(String, String, Object) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate

convertAndSend(Object, MessagePostProcessor) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate

convertAndSend(String, Object, MessagePostProcessor) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate

convertAndSend(String, String, Object, MessagePostProcessor) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate

convertRabbitAccessException(Exception) - Method in class org.springframework.amqp.rabbit.connection.RabbitAccessor

convertRabbitAccessException(Throwable) - Static method in class org.springframework.amqp.rabbit.connection.RabbitUtils

convertSendAndReceive(Object) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate

convertSendAndReceive(String, Object) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate

convertSendAndReceive(String, String, Object) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate

createBareConnection() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory

createBlockingQueueConsumer() - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer

createChannel(boolean) - Method in interface org.springframework.amqp.rabbit.connection.Connection

Create a new channel, using an internally allocated channel number.

createChannel(Connection) - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.ResourceFactory

Create a new RabbitMQ Session for registration with a RabbitResourceHolder.

createChannel(boolean) - Method in class org.springframework.amqp.rabbit.connection.SimpleConnection

createConnection() - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory

createConnection() - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactory

createConnection() - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.ResourceFactory

Create a new RabbitMQ Connection for registration with a RabbitResourceHolder.

createConnection() - Method in class org.springframework.amqp.rabbit.connection.RabbitAccessor

Create a RabbitMQ Connection via this template's ConnectionFactory and its host and port values.

createConnection() - Method in class org.springframework.amqp.rabbit.connection.SingleConnectionFactory

createElementDescription(Element) - Static method in class org.springframework.amqp.rabbit.config.NamespaceUtils

Provides a user friendly description of an element based on its node name and, if available, its "id" attribute value.

createRabbitTemplate(ConnectionFactory) - Method in class org.springframework.amqp.rabbit.core.support.RabbitGatewaySupport

Create a RabbitTemplate for the given ConnectionFactory.

D

declareBinding(Binding) - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin

declareExchange(Exchange) - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin

declareQueue(Queue) - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin

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

Declares a server-named exclusive, autodelete, non-durable queue.

declareTransactional(Channel) - Static method in class org.springframework.amqp.rabbit.connection.RabbitUtils

Declare to that broker that a channel is going to be used transactionally, and convert exceptions that arise.

DEFAULT_PORT - Static variable in class org.springframework.amqp.rabbit.connection.RabbitUtils

DEFAULT_PREFETCH_COUNT - Static variable in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer

DEFAULT_RECEIVE_TIMEOUT - Static variable in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer

DEFAULT_RECOVERY_INTERVAL - Static variable in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer

The default recovery interval: 5000 ms = 5 seconds.

DEFAULT_SHUTDOWN_TIMEOUT - Static variable in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer

DefaultMessagePropertiesConverter - Class in org.springframework.amqp.rabbit.support

Default implementation of the MessagePropertiesConverter strategy.

DefaultMessagePropertiesConverter() - Constructor for class org.springframework.amqp.rabbit.support.DefaultMessagePropertiesConverter

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

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

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

destroy() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory

destroy() - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory

Close the underlying shared connection.

destroy() - Method in class org.springframework.amqp.rabbit.connection.SingleConnectionFactory

Close the underlying shared connection.

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

Calls AbstractMessageListenerContainer.shutdown() when the BeanFactory destroys the container instance.

DirectExchangeParser - Class in org.springframework.amqp.rabbit.config

DirectExchangeParser() - Constructor for class org.springframework.amqp.rabbit.config.DirectExchangeParser

doBegin(Object, TransactionDefinition) - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager

doCleanupAfterCompletion(Object) - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager

doCommit(DefaultTransactionStatus) - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager

doCreateConnection() - Method in class org.springframework.amqp.rabbit.connection.SingleConnectionFactory

Create a Connection.

doGetTransaction() - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager

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

Register any invokers within this container.

doInitialize() - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer

Creates the specified number of concurrent consumers, in the form of a Rabbit Channel plus associated MessageConsumer.

doInRabbit(Channel) - Method in interface org.springframework.amqp.rabbit.core.ChannelCallback

Execute any number of operations against the supplied RabbitMQ Channel, possibly returning a result.

doInvokeListener(ChannelAwareMessageListener, Channel, Message) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer

Invoke the specified listener as Spring ChannelAwareMessageListener, exposing a new Rabbit Session (potentially with its own transaction) to the listener if demanded.

doInvokeListener(MessageListener, Message) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer

Invoke the specified listener as Spring Rabbit MessageListener.

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

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

doResume(Object, Object) - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager

doRollback(DefaultTransactionStatus) - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager

doSend(Channel, String, String, Message) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate

Send the given message to the specified exchange.

doSendAndReceive(String, String, Message) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate

Send a message and wait for a reply.

doSetRollbackOnly(DefaultTransactionStatus) - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager

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

Close the registered invokers.

doShutdown() - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer

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

Start this container, and notify all invoker tasks.

doStart() - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer

Re-initializes this container's Rabbit message consumers, if not initialized already.

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

This method is invoked when the container is stopping.

doStop() - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer

doSuspend(Object) - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager

E

execute(ChannelCallback<T>) - Method in interface org.springframework.amqp.rabbit.core.RabbitOperations

execute(ChannelCallback<T>) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate

executeListener(Channel, Message) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer

Execute the specified listener, committing or rolling back the transaction afterwards (if necessary).

extractMessage(Message) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter

Extract the message body from the given Rabbit message.

F

FanoutExchangeParser - Class in org.springframework.amqp.rabbit.config

FanoutExchangeParser() - Constructor for class org.springframework.amqp.rabbit.config.FanoutExchangeParser

FatalListenerExecutionException - Exception in org.springframework.amqp.rabbit.listener

Exception to be thrown when the execution of a listener method failed unrecoverably.

FatalListenerExecutionException(String, Throwable) - Constructor for exception org.springframework.amqp.rabbit.listener.FatalListenerExecutionException

Constructor for ListenerExecutionFailedException.

FatalListenerExecutionException(String) - Constructor for exception org.springframework.amqp.rabbit.listener.FatalListenerExecutionException

Constructor for ListenerExecutionFailedException.

FatalListenerStartupException - Exception in org.springframework.amqp.rabbit.listener

Exception to be thrown when the execution of a listener method failed on startup.

FatalListenerStartupException(String, Throwable) - Constructor for exception org.springframework.amqp.rabbit.listener.FatalListenerStartupException

Constructor for ListenerExecutionFailedException.

fromMessageProperties(MessageProperties, String) - Method in class org.springframework.amqp.rabbit.support.DefaultMessagePropertiesConverter

fromMessageProperties(MessageProperties, String) - Method in interface org.springframework.amqp.rabbit.support.MessagePropertiesConverter

G

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

getActiveConsumerCount() - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer

getApplicationId() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender

getBeanClass(Element) - Method in class org.springframework.amqp.rabbit.config.DirectExchangeParser

getBeanClass(Element) - Method in class org.springframework.amqp.rabbit.config.FanoutExchangeParser

getBeanClass(Element) - Method in class org.springframework.amqp.rabbit.config.HeadersExchangeParser

getBeanClass(Element) - Method in class org.springframework.amqp.rabbit.config.QueueParser

getBeanClass(Element) - Method in class org.springframework.amqp.rabbit.config.TopicExchangeParser

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

Return the bean name that this listener container has been assigned in its containing bean factory, if any.

getChannel(RabbitResourceHolder) - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.ResourceFactory

Fetch an appropriate Channel from the given RabbitResourceHolder.

getChannel(RabbitResourceHolder) - Method in class org.springframework.amqp.rabbit.connection.RabbitAccessor

Fetch an appropriate Channel from the given RabbitResourceHolder.

getChannel() - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder

getChannel() - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer

getChannelCacheSize() - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory

getChannelListener() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory

A composite channel listener to be used by subclasses when creating and closing channels.

getConnection(RabbitResourceHolder) - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.ResourceFactory

Fetch an appropriate Connection from the given RabbitResourceHolder.

getConnection(RabbitResourceHolder) - Method in class org.springframework.amqp.rabbit.connection.RabbitAccessor

Fetch an appropriate Connection from the given RabbitResourceHolder.

getConnection() - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder

getConnection(Class<? extends Connection>) - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder

getConnectionFactory() - Method in class org.springframework.amqp.rabbit.connection.RabbitAccessor

Return the ConnectionFactory that this accessor uses for obtaining RabbitMQ Connections.

getConnectionFactory() - Method in class org.springframework.amqp.rabbit.core.support.RabbitGatewaySupport

Return the Rabbit ConnectionFactory used by the gateway.

getConnectionFactory() - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager

getConnectionListener() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory

A composite connection listener to be used by subclasses when creating and closing connections.

getConsumerTag() - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer

getContentEncoding() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender

getContentType() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender

getCount() - Method in class org.springframework.amqp.rabbit.listener.ActiveObjectCounter

getDefaultHostName() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory

getDefaultListenerMethod() - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter

Return the name of the default listener method to delegate to.

getDelegate() - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter

Return the target object to delegate message listening to.

getEvent() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender.Event

getExchangeName() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender

getExchangeType() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender

getHost() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory

getHost() - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactory

getHost() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender

getKey(Message) - Method in interface org.springframework.amqp.rabbit.retry.MessageKeyGenerator

Generate a unique key for the message that is repeatable on redelivery.

getListenerMethodName(Message, Object) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter

Determine the name of the listener method that is supposed to handle the given message.

getMaxSenderRetries() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender

getMessageConverter() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate

Return the message converter for this template.

getMessageConverter() - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter

Return the converter that will convert incoming Rabbit messages to listener method arguments, and objects returned from listener methods back to Rabbit messages.

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

Return the message listener object to register.

getMessageRecoverer() - Method in class org.springframework.amqp.rabbit.config.AbstractRetryOperationsInterceptorFactoryBean

getObject() - Method in class org.springframework.amqp.rabbit.config.BindingFactoryBean

getObject() - Method in class org.springframework.amqp.rabbit.config.StatefulRetryOperationsInterceptorFactoryBean

getObject() - Method in class org.springframework.amqp.rabbit.config.StatelessRetryOperationsInterceptorFactoryBean

getObjectType() - Method in class org.springframework.amqp.rabbit.config.BindingFactoryBean

getObjectType() - Method in class org.springframework.amqp.rabbit.config.StatefulRetryOperationsInterceptorFactoryBean

getObjectType() - Method in class org.springframework.amqp.rabbit.config.StatelessRetryOperationsInterceptorFactoryBean

getPassword() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender

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

Return the phase in which this container will be started and stopped.

getPort() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory

getPort() - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactory

getPort() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender

getProperties() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender.Event

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

Return the name of the queue to receive messages from.

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

getRabbitTemplate() - Method in class org.springframework.amqp.rabbit.core.support.RabbitGatewaySupport

Return the RabbitTemplate for the gateway.

getReceivedExchange(Message) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter

getReplyToAddress(Message) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter

Determine a reply-to Address for the given message.

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

getResourceFactory() - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager

getRetryOperations() - Method in class org.springframework.amqp.rabbit.config.AbstractRetryOperationsInterceptorFactoryBean

getRoutingKeyPattern() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender

getSenderPoolSize() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender

getTargetChannel() - Method in interface org.springframework.amqp.rabbit.connection.ChannelProxy

Return the target Channel of this proxy.

getTargetConnection() - Method in interface org.springframework.amqp.rabbit.connection.ConnectionProxy

Return the target Channel of this proxy.

getTransactionalResourceHolder(ConnectionFactory, boolean) - Static method in class org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils

Obtain a RabbitMQ Channel that is synchronized with the current transaction, if any.

getTransactionalResourceHolder() - Method in class org.springframework.amqp.rabbit.connection.RabbitAccessor

getUsername() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender

getVirtualHost() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory

getVirtualHost() - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactory

getVirtualHost() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender

H

handleListenerException(Throwable) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer

Handle the given exception that arose during listener execution.

handleListenerException(Throwable) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter

Handle the given exception that arose during listener execution.

handleResult(Object, Message, Channel) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter

Handle the given result object returned from the listener method, sending a response message back.

handleStartupFailure(Throwable) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer

Wait for a period determined by the recoveryInterval to give the container a chance to recover from consumer startup failure, e.g.

HeadersExchangeParser - Class in org.springframework.amqp.rabbit.config

HeadersExchangeParser() - Constructor for class org.springframework.amqp.rabbit.config.HeadersExchangeParser

I

incrementRetries() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender.Event

init() - Method in class org.springframework.amqp.rabbit.config.RabbitNamespaceHandler

initDefaultStrategies() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate

initDefaultStrategies() - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter

Initialize the default implementations for the adapter's strategies.

initGateway() - Method in class org.springframework.amqp.rabbit.core.support.RabbitGatewaySupport

Subclasses can override this for custom initialization behavior.

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

Declares all the exchanges, queues and bindings in the enclosing application context, if any.

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

Initialize this container.

initializeConsumers() - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer

invokeErrorHandler(Throwable) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer

Invoke the registered ErrorHandler, if any.

invokeListener(Channel, Message) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer

Invoke the specified listener: either as standard MessageListener or (preferably) as SessionAwareMessageListener.

invokeListener(Channel, Message) - Method in interface org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.ContainerDelegate

invokeListener(Channel, Message) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer

invokeListenerMethod(String, Object[]) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter

Invoke the specified listener method.

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

Return whether this container is currently active, that is, whether it has been set up but not shut down yet.

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

Checks the attribute to see if it is defined in the given element.

isAutoDelete() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender

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

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

isChannelLocallyTransacted(Channel) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate

Check whether the given Channel is locally transacted, that is, whether its transaction is managed by this template's Channel handling and not by an external transaction coordinator.

isChannelLocallyTransacted(Channel) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer

Check whether the given Channel is locally transacted, that is, whether its transaction is managed by this listener container's Channel handling and not by an external transaction coordinator.

isChannelLocallyTransacted(Channel) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer

isChannelTransacted() - Method in class org.springframework.amqp.rabbit.connection.RabbitAccessor

isChannelTransactional(Channel, ConnectionFactory) - Static method in class org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils

Determine whether the given RabbitMQ Channel is transactional, that is, bound to the current thread by Spring's transaction facilities.

isChannelTransactional() - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder

isDeclareExchange() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender

isDurable() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender

isExistingTransaction(Object) - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager

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

Return whether to expose the listener Channel to a registered ChannelAwareMessageListener.

isFrozen() - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder

isNew(Message) - Method in interface org.springframework.amqp.rabbit.retry.NewMessageIdentifier

Query a message to see if it has been seen before.

isOpen() - Method in interface org.springframework.amqp.rabbit.connection.Connection

Flag to indicate the status of the connection.

isOpen() - Method in class org.springframework.amqp.rabbit.connection.SimpleConnection

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

Determine whether this container is currently running, that is, whether it has been started and not stopped yet.

isSingleton() - Method in class org.springframework.amqp.rabbit.config.AbstractRetryOperationsInterceptorFactoryBean

isSingleton() - Method in class org.springframework.amqp.rabbit.config.BindingFactoryBean

isSingleton() - Method in class org.springframework.amqp.rabbit.config.StatefulRetryOperationsInterceptorFactoryBean

isSingleton() - Method in class org.springframework.amqp.rabbit.config.StatelessRetryOperationsInterceptorFactoryBean

isSynchedLocalTransactionAllowed() - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.ResourceFactory

Return whether to allow for a local RabbitMQ transaction that is synchronized with a Spring-managed transaction (where the main transaction might be a JDBC-based one for a specific DataSource, for example), with the RabbitMQ transaction committing right after the main transaction.

L

ListenerExecutionFailedException - Exception in org.springframework.amqp.rabbit.listener

Exception to be thrown when the execution of a listener method failed.

ListenerExecutionFailedException(String, Throwable) - Constructor for exception org.springframework.amqp.rabbit.listener.ListenerExecutionFailedException

Constructor for ListenerExecutionFailedException.

logger - Variable in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory

logger - Variable in class org.springframework.amqp.rabbit.connection.RabbitAccessor

Logger available to subclasses

logger - Variable in class org.springframework.amqp.rabbit.core.RabbitAdmin

Logger available to subclasses

logger - Variable in class org.springframework.amqp.rabbit.core.support.RabbitGatewaySupport

Logger available to subclasses

logger - Variable in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter

Logger available to subclasses

M

maybeDeclareExchange() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender

Maybe declare the exchange.

MessageKeyGenerator - Interface in org.springframework.amqp.rabbit.retry

MessageListenerAdapter - Class in org.springframework.amqp.rabbit.listener.adapter

Message listener adapter that delegates the handling of messages to target listener methods via reflection, with flexible message type conversion.

MessageListenerAdapter() - Constructor for class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter

Create a new MessageListenerAdapter with default settings.

MessageListenerAdapter(Object) - Constructor for class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter

Create a new MessageListenerAdapter for the given delegate.

MessageListenerAdapter(Object, MessageConverter) - Constructor for class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter

Create a new MessageListenerAdapter for the given delegate.

MessagePropertiesConverter - Interface in org.springframework.amqp.rabbit.support

Strategy interface for converting between Spring AMQP MessageProperties and RabbitMQ BasicProperties.

MessageRecoverer - Interface in org.springframework.amqp.rabbit.retry

MessageRejectedWhileStoppingException - Exception in org.springframework.amqp.rabbit.listener

Exception class that indicates a rejected message on shutdown.

MessageRejectedWhileStoppingException() - Constructor for exception org.springframework.amqp.rabbit.listener.MessageRejectedWhileStoppingException

N

NamespaceUtils - Class in org.springframework.amqp.rabbit.config

Shared utility methods for namespace parsers.

NamespaceUtils() - Constructor for class org.springframework.amqp.rabbit.config.NamespaceUtils

NewMessageIdentifier - Interface in org.springframework.amqp.rabbit.retry

An optimization for stateful retry of message processing.

nextMessage() - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer

Main application-side API: wait for the next message delivery and return it.

nextMessage(long) - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer

Main application-side API: wait for the next message delivery and return it.

O

onClose(Connection) - Method in class org.springframework.amqp.rabbit.connection.CompositeConnectionListener

onClose(Connection) - Method in interface org.springframework.amqp.rabbit.connection.ConnectionListener

onCreate(Channel, boolean) - Method in interface org.springframework.amqp.rabbit.connection.ChannelListener

onCreate(Channel, boolean) - Method in class org.springframework.amqp.rabbit.connection.CompositeChannelListener

onCreate(Connection) - Method in class org.springframework.amqp.rabbit.connection.CompositeConnectionListener

onCreate(Connection) - Method in interface org.springframework.amqp.rabbit.connection.ConnectionListener

onMessage(Message, Channel) - Method in interface org.springframework.amqp.rabbit.core.ChannelAwareMessageListener

Callback for processing a received Rabbit message.

onMessage(Message) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter

Rabbit MessageListener entry point.

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

Spring ChannelAwareMessageListener entry point.

org.springframework.amqp.rabbit.config - package org.springframework.amqp.rabbit.config

org.springframework.amqp.rabbit.connection - package org.springframework.amqp.rabbit.connection

org.springframework.amqp.rabbit.core - package org.springframework.amqp.rabbit.core

org.springframework.amqp.rabbit.core.support - package org.springframework.amqp.rabbit.core.support

org.springframework.amqp.rabbit.listener - package org.springframework.amqp.rabbit.listener

org.springframework.amqp.rabbit.listener.adapter - package org.springframework.amqp.rabbit.listener.adapter

org.springframework.amqp.rabbit.log4j - package org.springframework.amqp.rabbit.log4j

org.springframework.amqp.rabbit.retry - package org.springframework.amqp.rabbit.retry

org.springframework.amqp.rabbit.support - package org.springframework.amqp.rabbit.support

org.springframework.amqp.rabbit.transaction - package org.springframework.amqp.rabbit.transaction

ORIGINAL_DEFAULT_LISTENER_METHOD - Static variable in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter

Out-of-the-box value for the default listener method: "handleMessage".

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

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

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

Post-process the given message producer before using it to send the response.

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

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

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

Q

QueueParser - Class in org.springframework.amqp.rabbit.config

QueueParser() - Constructor for class org.springframework.amqp.rabbit.config.QueueParser

R

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

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

RabbitAdmin - Class in org.springframework.amqp.rabbit.core

RabbitMQ implementation of portable AMQP administrative operations for AMQP >= 0.9.1

RabbitAdmin(ConnectionFactory) - Constructor for class org.springframework.amqp.rabbit.core.RabbitAdmin

RabbitGatewaySupport - Class in org.springframework.amqp.rabbit.core.support

Convenient super class for application classes that need JMS access.

RabbitGatewaySupport() - Constructor for class org.springframework.amqp.rabbit.core.support.RabbitGatewaySupport

RabbitNamespaceHandler - Class in org.springframework.amqp.rabbit.config

Namespace handler for Rabbit.

RabbitNamespaceHandler() - Constructor for class org.springframework.amqp.rabbit.config.RabbitNamespaceHandler

RabbitOperations - Interface in org.springframework.amqp.rabbit.core

Rabbit specific methods for Amqp functionality.

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

Rabbit resource holder, wrapping a RabbitMQ Connection and Channel.

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

Create a new RabbitResourceHolder that is open for resources to be added.

RabbitResourceHolder(Channel) - Constructor for class org.springframework.amqp.rabbit.connection.RabbitResourceHolder

RabbitTemplate - Class in org.springframework.amqp.rabbit.core

Helper class that simplifies synchronous RabbitMQ access code.

RabbitTemplate() - Constructor for class org.springframework.amqp.rabbit.core.RabbitTemplate

RabbitTemplate(ConnectionFactory) - Constructor for class org.springframework.amqp.rabbit.core.RabbitTemplate

RabbitTransactionManager - Class in org.springframework.amqp.rabbit.transaction

PlatformTransactionManager implementation for a single Rabbit ConnectionFactory.

RabbitTransactionManager() - Constructor for class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager

Create a new RabbitTransactionManager for bean-style usage.

RabbitTransactionManager(ConnectionFactory) - Constructor for class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager

Create a new RabbitTransactionManager, given a ConnectionFactory.

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

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

receive() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate

receive(String) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate

receiveAndConvert() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate

receiveAndConvert(String) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate

recover(Message, Throwable) - Method in interface org.springframework.amqp.rabbit.retry.MessageRecoverer

Callback for message that was consumed but failed all retry attempts.

registerDeliveryTag(ConnectionFactory, Channel, Long) - Static method in class org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils

release(T) - Method in class org.springframework.amqp.rabbit.listener.ActiveObjectCounter

releaseResources(RabbitResourceHolder) - Static method in class org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils

removeBinding(Binding) - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin

requiresLayout() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender

reset() - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory

Reset the Channel cache and underlying shared Connection, to be reinitialized on next access.

reset() - Method in class org.springframework.amqp.rabbit.listener.ActiveObjectCounter

rollbackAll() - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder

rollbackIfNecessary(Channel) - Static method in class org.springframework.amqp.rabbit.connection.RabbitUtils

rollbackOnExceptionIfNecessary(Throwable) - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer

Perform a rollback, handling rollback exceptions properly.

run() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender.EventSender

S

send(Message) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate

send(String, Message) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate

send(String, String, Message) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate

sendAndReceive(Message) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate

sendAndReceive(String, Message) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate

sendAndReceive(String, String, Message) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate

sendResponse(Channel, Address, Message) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter

Send the given response message to the given destination.

setAcknowledgeMode(AcknowledgeMode) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer

Flag controlling the behaviour of the container with respect to message acknowledgement.

setAdviceChain(Advice[]) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer

Public setter for the Advice to apply to listener executions.

setApplicationContext(ApplicationContext) - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin

setApplicationId(String) - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender

setArguments(Map<String, Object>) - Method in class org.springframework.amqp.rabbit.config.BindingFactoryBean

setAutoDelete(boolean) - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender

setAutoStartup(boolean) - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin

setAutoStartup(boolean) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer

Set whether to automatically start the container after initialization.

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

setChannelCacheSize(int) - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory

setChannelListeners(List<? extends ChannelListener>) - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory

setChannelTransacted(boolean) - Method in class org.springframework.amqp.rabbit.connection.RabbitAccessor

Flag to indicate that channels created by this component will be transactional.

setConcurrentConsumers(int) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer

Specify the number of concurrent consumers to create.

setConnectionFactory(ConnectionFactory) - Method in class org.springframework.amqp.rabbit.connection.RabbitAccessor

Set the ConnectionFactory to use for obtaining RabbitMQ Connections.

setConnectionFactory(ConnectionFactory) - Method in class org.springframework.amqp.rabbit.core.support.RabbitGatewaySupport

Set the Rabbit connection factory to be used by the gateway.

setConnectionFactory(ConnectionFactory) - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager

setConnectionListeners(List<? extends ConnectionListener>) - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory

setConnectionListeners(List<? extends ConnectionListener>) - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory

setConnectionListeners(List<? extends ConnectionListener>) - Method in class org.springframework.amqp.rabbit.connection.SingleConnectionFactory

setContentEncoding(String) - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender

setContentType(String) - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender

setDeclareExchange(boolean) - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender

setDefaultListenerMethod(String) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter

Specify the name of the default listener method to delegate to, for the case where no specific listener method has been determined.

setDelegate(Object) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter

Set a target object to delegate message listening to.

setDelegates(List<? extends ChannelListener>) - Method in class org.springframework.amqp.rabbit.connection.CompositeChannelListener

setDelegates(List<? extends ConnectionListener>) - Method in class org.springframework.amqp.rabbit.connection.CompositeConnectionListener

setDestinationExchange(Exchange) - Method in class org.springframework.amqp.rabbit.config.BindingFactoryBean

setDestinationQueue(Queue) - Method in class org.springframework.amqp.rabbit.config.BindingFactoryBean

setDurable(boolean) - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender

setEncoding(String) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate

The encoding to use when inter-converting between byte arrays and Strings in message properties.

setEncoding(String) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter

The encoding to use when inter-converting between byte arrays and Strings in message properties.

setErrorHandler(ErrorHandler) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer

Set an ErrorHandler to be invoked in case of any uncaught exceptions thrown while processing a Message.

setExchange(String) - Method in class org.springframework.amqp.rabbit.config.BindingFactoryBean

setExchange(String) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate

setExchangeName(String) - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender

setExchangeType(String) - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender

setExposeListenerChannel(boolean) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer

Set whether to expose the listener Rabbit Channel to a registered ChannelAwareMessageListener as well as to RabbitTemplate calls.

setHost(String) - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory

setHost(String) - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender

setImmediatePublish(boolean) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter

setMandatoryPublish(boolean) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter

setMaxSenderRetries(int) - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender

setMessageConverter(MessageConverter) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate

Set the message converter for this template.

setMessageConverter(MessageConverter) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter

Set the converter that will convert incoming Rabbit messages to listener method arguments, and objects returned from listener methods back to Rabbit messages.

setMessageKeyGeneretor(MessageKeyGenerator) - Method in class org.springframework.amqp.rabbit.config.StatefulRetryOperationsInterceptorFactoryBean

setMessageListener(Object) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer

Set the message listener implementation to register.

setMessagePropertiesConverter(MessagePropertiesConverter) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate

Set the MessagePropertiesConverter for this template.

setMessagePropertiesConverter(MessagePropertiesConverter) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer

Set the MessagePropertiesConverter for this listener container.

setMessageRecoverer(MessageRecoverer) - Method in class org.springframework.amqp.rabbit.config.AbstractRetryOperationsInterceptorFactoryBean

setNewMessageIdentifier(NewMessageIdentifier) - Method in class org.springframework.amqp.rabbit.config.StatefulRetryOperationsInterceptorFactoryBean

setPassword(String) - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory

setPassword(String) - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender

setPhase(int) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer

Specify the phase in which this container should be started and stopped.

setPort(int) - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory

setPort(int) - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender

setPrefetchCount(int) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer

Tells the broker how many messages to send to each consumer in a single request.

setQueue(String) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate

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

Set the name of the queue to receive messages from.

setQueues(Queue...) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer

setRabbitTemplate(RabbitTemplate) - Method in class org.springframework.amqp.rabbit.core.support.RabbitGatewaySupport

Set the RabbitTemplate for the gateway.

setReceiveTimeout(long) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer

setRecoveryInterval(long) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer

Specify the interval between recovery attempts, in milliseconds.

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

Populates the specified bean definition property with the reference to a bean.

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

Populates the bean definition property corresponding to the specified attributeName with the reference to a bean identified by the value of that attribute if the attribute is defined in the given element.

setReplyTimeout(long) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate

Specify the timeout in milliseconds to be used when waiting for a reply Message when using one of the sendAndReceive methods.

setResponseExchange(String) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter

Set the exchange to use when sending response messages.

setResponseRoutingKey(String) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter

Set the routing key to use when sending response messages.

setRetryOperations(RetryOperations) - Method in class org.springframework.amqp.rabbit.config.AbstractRetryOperationsInterceptorFactoryBean

setRoutingKey(String) - Method in class org.springframework.amqp.rabbit.config.BindingFactoryBean

setRoutingKey(String) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate

setRoutingKeyPattern(String) - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender

setSenderPoolSize(int) - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender

setShutdownTimeout(long) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer

The time to wait for workers in milliseconds after the container is stopped, and before the connection is forced closed.

setTaskExecutor(Executor) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer

setTransactionAttribute(TransactionAttribute) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer

setTransactionManager(PlatformTransactionManager) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer

setTxSize(int) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer

Tells the container how many messages to process in a single transaction (if the channel is transactional).

setUsername(String) - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory

setUsername(String) - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender

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

Populates the specified bean definition property with the value of the attribute whose name is provided if that attribute is defined in the given element.

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

Populates the bean definition property corresponding to the specified attributeName with the value of that attribute if it is defined in the given element.

setVirtualHost(String) - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory

setVirtualHost(String) - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender

sharedConnectionEnabled() - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer

Always use a shared Rabbit Connection.

shouldGenerateIdAsFallback() - Method in class org.springframework.amqp.rabbit.config.AbstractExchangeParser

shouldGenerateIdAsFallback() - Method in class org.springframework.amqp.rabbit.config.QueueParser

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

Stop the shared Connection, call AbstractMessageListenerContainer.doShutdown(), and close this container.

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

SimpleConnection(Connection) - Constructor for class org.springframework.amqp.rabbit.connection.SimpleConnection

SimpleMessageListenerContainer - Class in org.springframework.amqp.rabbit.listener

SimpleMessageListenerContainer() - Constructor for class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer

Default constructor for convenient dependency injection via setters.

SimpleMessageListenerContainer(ConnectionFactory) - Constructor for class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer

Create a listener container from the connection factory (mandatory).

SimpleMessageListenerContainer.ContainerDelegate - Interface in org.springframework.amqp.rabbit.listener

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

A ConnectionFactory implementation that returns the same Connections from all SingleConnectionFactory.createConnection() calls, and ignores calls to Connection.close().

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

Create a new SingleConnectionFactory initializing the hostname to be the value returned from InetAddress.getLocalHost(), or "localhost" if getLocalHost() throws an exception.

SingleConnectionFactory(int) - Constructor for class org.springframework.amqp.rabbit.connection.SingleConnectionFactory

Create a new SingleConnectionFactory given a host name.

SingleConnectionFactory(String) - Constructor for class org.springframework.amqp.rabbit.connection.SingleConnectionFactory

Create a new SingleConnectionFactory given a host name.

SingleConnectionFactory(String, int) - Constructor for class org.springframework.amqp.rabbit.connection.SingleConnectionFactory

Create a new SingleConnectionFactory given a host name.

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

Create a new SingleConnectionFactory for the given target ConnectionFactory.

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

Start this container.

start() - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer

startSenders() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender

Submit the required number of senders into the pool.

StatefulRetryOperationsInterceptorFactoryBean - Class in org.springframework.amqp.rabbit.config

Convenient factory bean for creating a stateful retry interceptor for use in a message listener container, giving you a large amount of control over the behaviour of a container when a listener fails.

StatefulRetryOperationsInterceptorFactoryBean() - Constructor for class org.springframework.amqp.rabbit.config.StatefulRetryOperationsInterceptorFactoryBean

StatelessRetryOperationsInterceptorFactoryBean - Class in org.springframework.amqp.rabbit.config

Convenient factory bean for creating a stateless retry interceptor for use in a message listener container, giving you a large amount of control over the behaviour of a container when a listener fails.

StatelessRetryOperationsInterceptorFactoryBean() - Constructor for class org.springframework.amqp.rabbit.config.StatelessRetryOperationsInterceptorFactoryBean

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

Stop this container.

stop(Runnable) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer

stop() - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer

T

toMessageProperties(AMQP.BasicProperties, Envelope, String) - Method in class org.springframework.amqp.rabbit.support.DefaultMessagePropertiesConverter

toMessageProperties(AMQP.BasicProperties, Envelope, String) - Method in interface org.springframework.amqp.rabbit.support.MessagePropertiesConverter

TopicExchangeParser - Class in org.springframework.amqp.rabbit.config

TopicExchangeParser() - Constructor for class org.springframework.amqp.rabbit.config.TopicExchangeParser

toString() - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory

toString() - Method in class org.springframework.amqp.rabbit.connection.SingleConnectionFactory

toString() - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer

V

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

Validate the configuration of this container.

validateConfiguration() - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer

Avoid the possibility of not configuring the CachingConnectionFactory in sync with the number of concurrent consumers.

W

wrapToListenerExecutionFailedExceptionIfNeeded(Exception) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer

A B C D E F G H I L M N O P Q R S T V W