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

A

AbstractAmqpConfiguration - Class in org.springframework.amqp.config
Abstract base class for code based configuration of Spring managed AMQP infrastructure, i.e.
AbstractAmqpConfiguration() - Constructor for class org.springframework.amqp.config.AbstractAmqpConfiguration
 
AbstractExchange - Class in org.springframework.amqp.core
Common properties that describe all exchange types.
AbstractExchange(String) - Constructor for class org.springframework.amqp.core.AbstractExchange
Construct a new Exchange for bean usage.
AbstractExchange(String, boolean, boolean) - Constructor for class org.springframework.amqp.core.AbstractExchange
Construct a new Exchange, given a name, durability flag, and auto-delete flag.
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.
AbstractRabbitConfiguration - Class in org.springframework.amqp.rabbit.config
Abstract base class for code based configuration of Spring managed Rabbit based broker infrastructure, i.e.
AbstractRabbitConfiguration() - Constructor for class org.springframework.amqp.rabbit.config.AbstractRabbitConfiguration
 
AcknowledgeMode - Enum in org.springframework.amqp.core
 
addChannel(Channel) - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder
 
addChannel(Channel, Connection) - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder
 
addConnection(Connection) - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder
 
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.
addDeliveryTag(Channel, long) - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder
 
Address - Class in org.springframework.amqp.core
Represents an address for publication of an AMQP message.
Address(String) - Constructor for class org.springframework.amqp.core.Address
Create an Address instance from a structured String in the form (exchangeType)://(exchange)/(routingKey) where examples of valid exchangeType values can be found in the ExchangeTypes static constants.
Address(String, String, String) - Constructor for class org.springframework.amqp.core.Address
Create an Address given the exchange type, exchange name and routing key.
addUser(String, String) - Method in class org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin
 
addUser(String, String) - Method in interface org.springframework.amqp.rabbit.admin.RabbitBrokerOperations
 
addVhost(String) - Method in class org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin
 
addVhost(String) - Method in interface org.springframework.amqp.rabbit.admin.RabbitBrokerOperations
 
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.support.RabbitAccessor
 
afterPropertiesSet() - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager
Make sure the ConnectionFactory has been set.
afterPropertiesSet() - Method in class org.springframework.amqp.support.converter.DefaultClassMapper
 
afterPropertiesSet() - Method in class org.springframework.amqp.support.converter.MarshallingMessageConverter
 
afterPropertiesSet() - Method in class org.springframework.erlang.connection.SimpleConnectionFactory
 
afterPropertiesSet() - Method in class org.springframework.erlang.connection.SingleConnectionFactory
 
afterPropertiesSet() - Method in class org.springframework.erlang.support.ErlangAccessor
 
amqpAdmin() - Method in class org.springframework.amqp.config.AbstractAmqpConfiguration
 
AmqpAdmin - Interface in org.springframework.amqp.core
Specifies a basic set of portable AMQP administrative operations for AMQP > 0.8
amqpAdmin() - Method in class org.springframework.amqp.rabbit.config.AbstractRabbitConfiguration
 
AmqpConnectException - Exception in org.springframework.amqp
RuntimeException wrapper for an ConnectException which can be commonly thrown from AMQP operations if the remote process dies or there is a network issue.
AmqpConnectException(ConnectException) - Constructor for exception org.springframework.amqp.AmqpConnectException
 
AmqpException - Exception in org.springframework.amqp
Base RuntimeException for errors that occur when executing AMQP operations.
AmqpException(String) - Constructor for exception org.springframework.amqp.AmqpException
 
AmqpException(Throwable) - Constructor for exception org.springframework.amqp.AmqpException
 
AmqpException(String, Throwable) - Constructor for exception org.springframework.amqp.AmqpException
 
AmqpIllegalStateException - Exception in org.springframework.amqp
Equivalent of an IllegalStateException but within the AmqpException hierarchy.
AmqpIllegalStateException(String) - Constructor for exception org.springframework.amqp.AmqpIllegalStateException
 
AmqpIOException - Exception in org.springframework.amqp
RuntimeException wrapper for an IOException which can be commonly thrown from AMQP operations.
AmqpIOException(IOException) - Constructor for exception org.springframework.amqp.AmqpIOException
 
AmqpTemplate - Interface in org.springframework.amqp.core
Specifies a basic set of AMQP operations.
AmqpUnsupportedEncodingException - Exception in org.springframework.amqp
RuntimeException for unsupported encoding in an AMQP operation.
AmqpUnsupportedEncodingException(Throwable) - Constructor for exception org.springframework.amqp.AmqpUnsupportedEncodingException
 
Application - Class in org.springframework.erlang.core
Describes an Erlang application.
Application(String, String, String) - Constructor for class org.springframework.erlang.core.Application
 

B

Background - Class in org.springframework.util.exec
Class to execute processes in the background.
Background() - Constructor for class org.springframework.util.exec.Background
 
Binding - Class in org.springframework.amqp.core
Simple container collecting information to describe a queue binding.
Binding(Queue, FanoutExchange) - Constructor for class org.springframework.amqp.core.Binding
 
Binding(Queue, HeadersExchange, Map<String, Object>) - Constructor for class org.springframework.amqp.core.Binding
 
Binding(Queue, DirectExchange) - Constructor for class org.springframework.amqp.core.Binding
 
Binding(Queue, DirectExchange, String) - Constructor for class org.springframework.amqp.core.Binding
 
Binding(Queue, TopicExchange, String) - Constructor for class org.springframework.amqp.core.Binding
 
BINDING_QUEUE_ATTR - Static variable in class org.springframework.amqp.rabbit.config.AbstractExchangeParser
 
BindingBuilder - Class in org.springframework.amqp.core
Basic builder class to create bindings for a more fluent API style in code based configuration.
BindingBuilder() - Constructor for class org.springframework.amqp.core.BindingBuilder
 
BindingBuilder.DirectExchangeRoutingKeyConfigurer - Class in org.springframework.amqp.core
 
BindingBuilder.ExchangeConfigurer - Class in org.springframework.amqp.core
 
BindingBuilder.HeadersExchangeMapConfigurer - Class in org.springframework.amqp.core
 
BindingBuilder.HeadersExchangeMapConfigurer.HeadersExchangeKeysBindingCreator - Class in org.springframework.amqp.core
 
BindingBuilder.HeadersExchangeMapConfigurer.HeadersExchangeMapBindingCreator - Class in org.springframework.amqp.core
 
BindingBuilder.HeadersExchangeMapConfigurer.HeadersExchangeSingleValueBindingCreator - Class in org.springframework.amqp.core
 
BindingBuilder.TopicExchangeRoutingKeyConfigurer - Class in org.springframework.amqp.core
 
bindResourceToTransaction(RabbitResourceHolder, ConnectionFactory, boolean) - Static method in class org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils
 
BlockingQueueConsumer - Class in org.springframework.amqp.rabbit.listener
Variation on QueueingConsumer in RabbitMQ, uses 'put' instead of 'add' and stored a reference to the consumerTag that was returned when this Consumer was registered with the channel so as to make it easy to close the consumer when shutting down.
BlockingQueueConsumer(Channel, AcknowledgeMode, boolean, int, String...) - Constructor for class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer
 
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
NOTE: this ConnectionFactory implementation is considered experimental at this stage.
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) - 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.
changeUserPassword(String, String) - Method in class org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin
 
changeUserPassword(String, String) - Method in interface org.springframework.amqp.rabbit.admin.RabbitBrokerOperations
 
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
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.
ClassMapper - Interface in org.springframework.amqp.support.converter
Strategy for setting metadata on messages such that one can create the class that needs to be instantiated when receiving a message.
cleanUp() - Method in class org.springframework.util.exec.ExecuteWatchdog
reset the monitor flag and the process.
clearPermissions(String) - Method in class org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin
 
clearPermissions(String, String) - Method in class org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin
 
clearPermissions(String) - Method in interface org.springframework.amqp.rabbit.admin.RabbitBrokerOperations
 
clearPermissions(String, String) - Method in interface org.springframework.amqp.rabbit.admin.RabbitBrokerOperations
 
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 interface org.springframework.erlang.connection.Connection
Close the connection to the remote node.
close() - Method in class org.springframework.erlang.connection.DefaultConnection
 
closeAll() - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder
 
closeChannel(Channel) - Static method in class org.springframework.amqp.rabbit.support.RabbitUtils
Close the given RabbitMQ Channel and ignore any thrown exception.
closeConnection(Connection) - Static method in class org.springframework.amqp.rabbit.support.RabbitUtils
Close the given RabbitMQ Connection and ignore any thrown exception.
closeConnection(Connection) - Method in class org.springframework.erlang.connection.SingleConnectionFactory
Close the given Connection.
closeMessageConsumer(Channel, String, boolean) - Static method in class org.springframework.amqp.rabbit.support.RabbitUtils
 
commitAll() - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder
 
commitIfNecessary(Channel, Message) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
Perform a commit or message acknowledgement, as appropriate.
commitIfNecessary(Channel) - Static method in class org.springframework.amqp.rabbit.support.RabbitUtils
Commit the Channel if not within a JTA transaction.
Connection - Interface in org.springframework.amqp.rabbit.connection
 
Connection - Interface in org.springframework.erlang.connection
A simple interface that is used to wrap access to the OtpConnection class in order to support caching of OptConnections via method interception.
ConnectionCallback<T> - Interface in org.springframework.erlang.core
Basic callback for use in ErlangTemplate
ConnectionFactory - Interface in org.springframework.amqp.rabbit.connection
An interface based ConnectionFactory for creating Connections.
ConnectionFactory - Interface in org.springframework.erlang.connection
An interface based ConnectionFactory for creating OtpConnections.
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 - Class in org.springframework.erlang.connection
 
ConnectionFactoryUtils() - Constructor for class org.springframework.erlang.connection.ConnectionFactoryUtils
 
ConnectionFactoryUtils.ResourceFactory - Interface in org.springframework.amqp.rabbit.connection
Callback interface for resource creation.
ConnectionParameters - Class in org.springframework.erlang.connection
Encapsulate properties to create a OtpConnection
ConnectionParameters(OtpSelf, OtpPeer) - Constructor for class org.springframework.erlang.connection.ConnectionParameters
 
ConnectionProxy - Interface in org.springframework.amqp.rabbit.connection
Subinterface of Connection to be implemented by Connection proxies.
ConnectionProxy - Interface in org.springframework.erlang.connection
Subinterface of Connection to be implemented by Connection proxies.
containsChannel(Channel) - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder
 
CONTENT_TYPE_BYTES - Static variable in class org.springframework.amqp.core.MessageProperties
 
CONTENT_TYPE_JSON - Static variable in class org.springframework.amqp.core.MessageProperties
 
CONTENT_TYPE_SERIALIZED_OBJECT - Static variable in class org.springframework.amqp.core.MessageProperties
 
CONTENT_TYPE_TEXT_PLAIN - Static variable in class org.springframework.amqp.core.MessageProperties
 
convertAndSend(Object) - Method in interface org.springframework.amqp.core.AmqpTemplate
 
convertAndSend(String, Object) - Method in interface org.springframework.amqp.core.AmqpTemplate
 
convertAndSend(String, String, Object) - Method in interface org.springframework.amqp.core.AmqpTemplate
 
convertAndSend(Object, MessagePostProcessor) - Method in interface org.springframework.amqp.core.AmqpTemplate
 
convertAndSend(String, Object, MessagePostProcessor) - Method in interface org.springframework.amqp.core.AmqpTemplate
 
convertAndSend(String, String, Object, MessagePostProcessor) - Method in interface org.springframework.amqp.core.AmqpTemplate
 
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
 
convertBasicTypeToErlang(Object) - Method in class org.springframework.erlang.support.converter.SimpleErlangConverter
 
convertErlangToBasicType(OtpErlangObject) - Method in class org.springframework.erlang.support.converter.SimpleErlangConverter
 
convertOtpAccessException(Exception) - Method in class org.springframework.erlang.core.ErlangTemplate
Convert the specified checked exception to a Spring runtime exception equivalent.
convertOtpAccessException(Exception) - Method in class org.springframework.erlang.support.ErlangAccessor
 
convertOtpAccessException(Exception) - Static method in class org.springframework.erlang.support.ErlangUtils
 
convertRabbitAccessException(Exception) - Method in class org.springframework.amqp.rabbit.support.RabbitAccessor
 
convertRabbitAccessException(Throwable) - Static method in class org.springframework.amqp.rabbit.support.RabbitUtils
 
convertSendAndReceive(Object) - Method in interface org.springframework.amqp.core.AmqpTemplate
 
convertSendAndReceive(String, Object) - Method in interface org.springframework.amqp.core.AmqpTemplate
 
convertSendAndReceive(String, String, Object) - Method in interface org.springframework.amqp.core.AmqpTemplate
 
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
 
createBlockingQueueConsumer(Channel) - 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 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.SingleConnectionFactory
 
createConnection() - Method in class org.springframework.amqp.rabbit.support.RabbitAccessor
Create a RabbitMQ Connection via this template's ConnectionFactory and its host and port values.
createConnection() - Method in interface org.springframework.erlang.connection.ConnectionFactory
 
createConnection() - Method in class org.springframework.erlang.connection.SimpleConnectionFactory
 
createConnection() - Method in class org.springframework.erlang.connection.SingleConnectionFactory
 
createConnection() - Method in class org.springframework.erlang.support.ErlangAccessor
 
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.
createErlangTemplate(ConnectionFactory) - Method in class org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin
 
createMessageProperties(AMQP.BasicProperties, Envelope, String) - Static method in class org.springframework.amqp.rabbit.support.RabbitUtils
 
createObjectInputStream(InputStream, String) - Method in class org.springframework.amqp.support.converter.SimpleMessageConverter
Create an ObjectInputStream for the given InputStream and codebase.
createProcessErrorPump(InputStream, OutputStream) - Method in class org.springframework.util.exec.PumpStreamHandler
 
createProcessOutputPump(InputStream, OutputStream) - Method in class org.springframework.util.exec.PumpStreamHandler
 
createPump(InputStream, OutputStream) - Method in class org.springframework.util.exec.PumpStreamHandler
Creates a stream pumper to copy the given input stream to the given output stream.
createRabbitTemplate(ConnectionFactory) - Method in class org.springframework.amqp.rabbit.core.support.RabbitGatewaySupport
Create a RabbitTemplate for the given ConnectionFactory.
createSharedConnection() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
Create a shared Connection for this container.

D

declareBinding(Binding) - Method in interface org.springframework.amqp.core.AmqpAdmin
Declare a binding of a queue to an exchange.
declareBinding(Binding) - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
 
declareExchange(Exchange) - Method in interface org.springframework.amqp.core.AmqpAdmin
Declare an exchange
declareExchange(Exchange) - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
 
declareQueue() - Method in interface org.springframework.amqp.core.AmqpAdmin
Declare a queue whose name is automatically named.
declareQueue(Queue) - Method in interface org.springframework.amqp.core.AmqpAdmin
Declare the given queue
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() - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder
Call this method once the channel Channel.txSelect() has been called
declareTransactional(Channel) - Static method in class org.springframework.amqp.rabbit.support.RabbitUtils
Declare to that broker that a channel is going to be used transactionally, and convert exceptions that arise.
DEFAULT - Static variable in class org.springframework.amqp.core.DirectExchange
 
DEFAULT_CHARSET - Static variable in class org.springframework.amqp.support.converter.JsonMessageConverter
 
DEFAULT_CHARSET - Static variable in class org.springframework.amqp.support.converter.SerializerMessageConverter
 
DEFAULT_CHARSET - Static variable in class org.springframework.amqp.support.converter.SimpleMessageConverter
 
DEFAULT_CLASSID_FIELD_NAME - Static variable in class org.springframework.amqp.support.converter.DefaultClassMapper
 
DEFAULT_PORT - Static variable in class org.springframework.amqp.rabbit.support.RabbitUtils
 
DEFAULT_RECEIVE_TIMEOUT - Static variable in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
 
DefaultClassMapper - Class in org.springframework.amqp.support.converter
 
DefaultClassMapper() - Constructor for class org.springframework.amqp.support.converter.DefaultClassMapper
 
DefaultConnection - Class in org.springframework.erlang.connection
Basic implementation of ConnectionProxy that delegates to an underlying OtpConnection.
DefaultConnection(OtpConnection) - Constructor for class org.springframework.erlang.connection.DefaultConnection
 
defaultExchange() - Method in class org.springframework.amqp.config.AbstractAmqpConfiguration
Provides convenient access to the default exchange which is always declared on the broker.
deleteExchange(String) - Method in interface org.springframework.amqp.core.AmqpAdmin
Delete an exchange.
deleteExchange(String) - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
 
deleteQueue(String) - Method in interface org.springframework.amqp.core.AmqpAdmin
Delete a queue, without regard for whether it is in use or has messages on it
deleteQueue(String, boolean, boolean) - Method in interface org.springframework.amqp.core.AmqpAdmin
Delete a queue
deleteQueue(String) - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
 
deleteQueue(String, boolean, boolean) - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
 
deleteUser(String) - Method in class org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin
 
deleteUser(String) - Method in interface org.springframework.amqp.rabbit.admin.RabbitBrokerOperations
 
deleteVhost(String) - Method in class org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin
 
deleteVhost(String) - Method in interface org.springframework.amqp.rabbit.admin.RabbitBrokerOperations
 
deserialize(byte[]) - Static method in class org.springframework.amqp.utils.SerializationUtils
 
deserialize(ObjectInputStream) - Static method in class org.springframework.amqp.utils.SerializationUtils
 
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.
destroy() - Method in class org.springframework.erlang.connection.SingleConnectionFactory
Close the underlying shared connection.
DIRECT - Static variable in class org.springframework.amqp.core.ExchangeTypes
 
DirectExchange - Class in org.springframework.amqp.core
Simple container collecting information to describe a direct exchange.
DirectExchange(String) - Constructor for class org.springframework.amqp.core.DirectExchange
 
DirectExchange(String, boolean, boolean) - Constructor for class org.springframework.amqp.core.DirectExchange
 
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.CachingConnectionFactory
 
doCreateConnection() - Method in class org.springframework.amqp.rabbit.connection.SingleConnectionFactory
Create a Connection.
doCreateConnection() - Method in class org.springframework.erlang.connection.SingleConnectionFactory
Create a JInterface Connection via this class's ConnectionFactory.
doExecuteListener(Channel, Message) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
Execute the specified listener, committing or rolling back the transaction afterwards (if necessary).
doGetTransaction() - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager
 
doInConnection(Connection) - Method in interface org.springframework.erlang.core.ConnectionCallback
Execute any number of operations against the supplied OTP connection, possibly returning a result.
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
 
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 the shared Connection, if any, 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
Notify all invoker tasks and stop the shared Connection, if any.
doStop() - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
 
doSuspend(Object) - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager
 

E

ErlangAccessor - Class in org.springframework.erlang.support
 
ErlangAccessor() - Constructor for class org.springframework.erlang.support.ErlangAccessor
 
ErlangBadRpcException - Exception in org.springframework.erlang
Exception thrown when an 'badrpc' is received from an Erlang RPC call.
ErlangBadRpcException(String) - Constructor for exception org.springframework.erlang.ErlangBadRpcException
 
ErlangBadRpcException(OtpErlangTuple) - Constructor for exception org.springframework.erlang.ErlangBadRpcException
 
ErlangConversionException - Exception in org.springframework.erlang.support.converter
 
ErlangConversionException(String, Throwable) - Constructor for exception org.springframework.erlang.support.converter.ErlangConversionException
 
ErlangConversionException(String) - Constructor for exception org.springframework.erlang.support.converter.ErlangConversionException
 
ErlangConverter - Interface in org.springframework.erlang.support.converter
Converter between Java and Erlang Types.
ErlangErrorRpcException - Exception in org.springframework.erlang
Exception thrown when an 'error' is received from an Erlang RPC call
ErlangErrorRpcException(String) - Constructor for exception org.springframework.erlang.ErlangErrorRpcException
 
ErlangErrorRpcException(OtpErlangTuple) - Constructor for exception org.springframework.erlang.ErlangErrorRpcException
 
ErlangOperations - Interface in org.springframework.erlang.core
Operations to perform against OTP/Erlang
ErlangTemplate - Class in org.springframework.erlang.core
 
ErlangTemplate(ConnectionFactory) - Constructor for class org.springframework.erlang.core.ErlangTemplate
 
ErlangUtils - Class in org.springframework.erlang.support
 
ErlangUtils() - Constructor for class org.springframework.erlang.support.ErlangUtils
 
Escape - Class in org.springframework.util.exec
 
Escape() - Constructor for class org.springframework.util.exec.Escape
 
escape(String) - Static method in class org.springframework.util.exec.Escape
Escape a string by quoting the magical elements (such as whitespace, quotes, slashes, etc.)
establishSharedConnection() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
Establish a shared Connection for this container.
exchange - Variable in class org.springframework.amqp.core.BindingBuilder.HeadersExchangeMapConfigurer
 
Exchange - Interface in org.springframework.amqp.core
 
ExchangeTypes - Class in org.springframework.amqp.core
Constants for the standard Exchange type names.
ExchangeTypes() - Constructor for class org.springframework.amqp.core.ExchangeTypes
 
exec(String[]) - Static method in class org.springframework.util.exec.Background
Execute the command (and its args, ala Runtime.exec), sending the output && error streams to the void.
exec(String[], File, boolean, File, boolean) - Static method in class org.springframework.util.exec.Background
Execute a command (and its args, ala Runtime.exec)
execute(ChannelCallback<T>) - Method in interface org.springframework.amqp.rabbit.core.RabbitOperations
 
execute(ChannelCallback<T>) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
 
execute(ConnectionCallback<T>) - Method in interface org.springframework.erlang.core.ErlangOperations
 
execute(ConnectionCallback<T>) - Method in class org.springframework.erlang.core.ErlangTemplate
 
Execute - Class in org.springframework.util.exec
Runs an external program.
Execute() - Constructor for class org.springframework.util.exec.Execute
Creates a new execute object using PumpStreamHandler for stream handling.
Execute(ExecuteStreamHandler) - Constructor for class org.springframework.util.exec.Execute
Creates a new execute object.
Execute(ExecuteStreamHandler, ExecuteWatchdog) - Constructor for class org.springframework.util.exec.Execute
Creates a new execute object.
execute() - Method in class org.springframework.util.exec.Execute
Runs a process defined by the command line and returns its exit status.
execute(Vector<String>, String, File) - Static method in class org.springframework.util.exec.Execute
 
execute(Vector<String>, Vector<String>, File) - Static method in class org.springframework.util.exec.Execute
 
execute(Vector<String>, Vector<String>, File, int) - Static method in class org.springframework.util.exec.Execute
Wrapper for common execution patterns
executeAndConvertRpc(String, String, ErlangConverter, Object...) - Method in interface org.springframework.erlang.core.ErlangOperations
 
executeAndConvertRpc(String, String, Object...) - Method in interface org.springframework.erlang.core.ErlangOperations
 
executeAndConvertRpc(String, String, ErlangConverter, Object...) - Method in class org.springframework.erlang.core.ErlangTemplate
 
executeAndConvertRpc(String, String, Object...) - Method in class org.springframework.erlang.core.ErlangTemplate
 
executeErlangRpc(String, String, OtpErlangList) - Method in interface org.springframework.erlang.core.ErlangOperations
 
executeErlangRpc(String, String, OtpErlangObject...) - Method in interface org.springframework.erlang.core.ErlangOperations
 
executeErlangRpc(String, String, OtpErlangList) - Method in class org.springframework.erlang.core.ErlangTemplate
 
executeErlangRpc(String, String, OtpErlangObject...) - Method in class org.springframework.erlang.core.ErlangTemplate
 
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).
executeRpc(String, String, Object...) - Method in interface org.springframework.erlang.core.ErlangOperations
 
executeRpc(String, String, Object...) - Method in class org.springframework.erlang.core.ErlangTemplate
 
ExecuteStreamHandler - Interface in org.springframework.util.exec
Used by Execute to handle input and output stream of subprocesses.
ExecuteWatchdog - Class in org.springframework.util.exec
Destroys a process running for too long.
ExecuteWatchdog(int) - Constructor for class org.springframework.util.exec.ExecuteWatchdog
Creates a new watchdog with a given timeout.
exist() - Method in class org.springframework.amqp.core.BindingBuilder.HeadersExchangeMapConfigurer.HeadersExchangeKeysBindingCreator
 
exists() - Method in class org.springframework.amqp.core.BindingBuilder.HeadersExchangeMapConfigurer.HeadersExchangeSingleValueBindingCreator
 
extractBasicProperties(Message, String) - Static method in class org.springframework.amqp.rabbit.support.RabbitUtils
 
extractBoolean(OtpErlangObject) - Static method in class org.springframework.erlang.support.converter.SimpleErlangConverter
 
extractLong(OtpErlangObject) - Static method in class org.springframework.erlang.support.converter.SimpleErlangConverter
 
extractMessage(Message) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter
Extract the message body from the given Rabbit message.
extractPid(OtpErlangObject) - Static method in class org.springframework.erlang.support.converter.SimpleErlangConverter
 

F

FANOUT - Static variable in class org.springframework.amqp.core.ExchangeTypes
 
FanoutExchange - Class in org.springframework.amqp.core
Simple container collecting information to describe a fanout exchange.
FanoutExchange(String) - Constructor for class org.springframework.amqp.core.FanoutExchange
 
FanoutExchange(String, boolean, boolean) - Constructor for class org.springframework.amqp.core.FanoutExchange
 
FanoutExchangeParser - Class in org.springframework.amqp.rabbit.config
 
FanoutExchangeParser() - Constructor for class org.springframework.amqp.rabbit.config.FanoutExchangeParser
 
forceResetNode() - Method in class org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin
 
forceResetNode() - Method in interface org.springframework.amqp.rabbit.admin.RabbitBrokerOperations
The forceResetNode command differs from RabbitBrokerOperations.resetNode() in that it resets the node unconditionally, regardless of the current management database state and cluster configuration.
from(Queue) - Static method in class org.springframework.amqp.core.BindingBuilder
 
fromClass(Class<?>, MessageProperties) - Method in interface org.springframework.amqp.support.converter.ClassMapper
 
fromClass(Class<?>, MessageProperties) - Method in class org.springframework.amqp.support.converter.DefaultClassMapper
 
fromErlang(OtpErlangObject) - Method in class org.springframework.amqp.rabbit.admin.RabbitControlErlangConverter.ListUsersConverter
 
fromErlang(OtpErlangObject) - Method in class org.springframework.amqp.rabbit.admin.RabbitControlErlangConverter.QueueInfoAllConverter
 
fromErlang(OtpErlangObject) - Method in class org.springframework.amqp.rabbit.admin.RabbitControlErlangConverter.StatusConverter
 
fromErlang(OtpErlangObject) - Method in interface org.springframework.erlang.support.converter.ErlangConverter
Convert from a Erlang data type to a Java object.
fromErlang(OtpErlangObject) - Method in class org.springframework.erlang.support.converter.SimpleErlangConverter
 
fromErlangRpc(String, String, OtpErlangObject) - Method in class org.springframework.amqp.rabbit.admin.RabbitControlErlangConverter
 
fromErlangRpc(String, String, OtpErlangObject) - Method in interface org.springframework.erlang.support.converter.ErlangConverter
 
fromErlangRpc(String, String, OtpErlangObject) - Method in class org.springframework.erlang.support.converter.SimpleErlangConverter
 
fromInt(int) - Static method in enum org.springframework.amqp.core.MessageDeliveryMode
 
fromMessage(Message) - Method in class org.springframework.amqp.support.converter.JsonMessageConverter
 
fromMessage(Message) - Method in class org.springframework.amqp.support.converter.MarshallingMessageConverter
Unmarshals the given Message into an object.
fromMessage(Message) - Method in interface org.springframework.amqp.support.converter.MessageConverter
Convert from a Rabbit GetResponse to a Java object.
fromMessage(Message) - Method in class org.springframework.amqp.support.converter.SerializerMessageConverter
Converts from a AMQP Message to an Object.
fromMessage(Message) - Method in class org.springframework.amqp.support.converter.SimpleMessageConverter
Converts from a AMQP Message to an Object.

G

generateKey(String, String) - Method in class org.springframework.amqp.rabbit.admin.RabbitControlErlangConverter
 
getAcknowledgeMode() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
 
getAcksUncommitted() - Method in class org.springframework.amqp.rabbit.admin.QueueInfo
 
getActiveConsumerCount() - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
 
getAppId() - Method in class org.springframework.amqp.core.MessageProperties
 
getArguments() - Method in class org.springframework.amqp.core.AbstractExchange
Return the collection of arbitrary arguments to use when declaring an exchange.
getArguments() - Method in class org.springframework.amqp.core.Binding
 
getArguments() - Method in interface org.springframework.amqp.core.Exchange
 
getArguments() - Method in class org.springframework.amqp.core.Queue
 
getArguments() - Method in class org.springframework.amqp.rabbit.admin.QueueInfo
 
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.
getBody() - Method in class org.springframework.amqp.core.Message
 
getChannel(RabbitResourceHolder) - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.ResourceFactory
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
 
getChannel(RabbitResourceHolder) - Method in class org.springframework.amqp.rabbit.support.RabbitAccessor
Fetch an appropriate Channel from the given RabbitResourceHolder.
getChannelCacheSize() - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
 
getClassIdFieldName() - Method in class org.springframework.amqp.support.converter.DefaultClassMapper
 
getClassMapper() - Method in class org.springframework.amqp.support.converter.JsonMessageConverter
 
getClusterId() - Method in class org.springframework.amqp.core.MessageProperties
 
getCommandline() - Method in class org.springframework.util.exec.Execute
Returns the commandline used to create a subprocess.
getCommandLineString() - Method in class org.springframework.util.exec.Execute
 
getConnection(RabbitResourceHolder) - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.ResourceFactory
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
 
getConnection(RabbitResourceHolder) - Method in class org.springframework.amqp.rabbit.support.RabbitAccessor
Fetch an appropriate Connection from the given RabbitResourceHolder.
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.support.RabbitAccessor
Return the ConnectionFactory that this accessor uses for obtaining RabbitMQ Connections.
getConnectionFactory() - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager
 
getConnectionFactory() - Method in class org.springframework.erlang.support.ErlangAccessor
 
getConsumers() - Method in class org.springframework.amqp.rabbit.admin.QueueInfo
 
getConsumerTag() - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer
 
getContentEncoding() - Method in class org.springframework.amqp.core.MessageProperties
 
getContentLength() - Method in class org.springframework.amqp.core.MessageProperties
 
getContentType() - Method in class org.springframework.amqp.core.MessageProperties
 
getConverter(String, String) - Method in class org.springframework.amqp.rabbit.admin.RabbitControlErlangConverter
 
getCorrelationId() - Method in class org.springframework.amqp.core.MessageProperties
 
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.
getDeliveryMode() - Method in class org.springframework.amqp.core.MessageProperties
 
getDeliveryTag() - Method in class org.springframework.amqp.core.MessageProperties
 
getDescription() - Method in class org.springframework.erlang.core.Application
 
getEnvironment() - Method in class org.springframework.util.exec.Execute
Returns the environment used to create a subprocess.
getErlangConverter() - Method in class org.springframework.erlang.core.ErlangTemplate
 
getErr() - Method in class org.springframework.util.exec.PumpStreamHandler
 
getException() - Method in class org.springframework.util.exec.ExecuteWatchdog
 
getExchange() - Method in class org.springframework.amqp.core.Binding
 
getExchangeName() - Method in class org.springframework.amqp.core.Address
 
getExchangeType() - Method in class org.springframework.amqp.core.Address
 
getExitValue() - Method in class org.springframework.util.exec.Execute
query the exit value of the process.
getExpiration() - Method in class org.springframework.amqp.core.MessageProperties
 
getHeaders() - Method in class org.springframework.amqp.core.MessageProperties
 
getHost() - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactory
 
getHost() - Method in class org.springframework.amqp.rabbit.connection.SingleConnectionFactory
 
getId() - Method in class org.springframework.erlang.core.Application
 
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.
getMemory() - Method in class org.springframework.amqp.rabbit.admin.QueueInfo
 
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.
getMessageCount() - Method in class org.springframework.amqp.core.MessageProperties
 
getMessageId() - Method in class org.springframework.amqp.core.MessageProperties
 
getMessageListener() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
Return the message listener object to register.
getMessageProperties() - Method in class org.springframework.amqp.core.Message
 
getMessages() - Method in class org.springframework.amqp.rabbit.admin.QueueInfo
 
getMessagesReady() - Method in class org.springframework.amqp.rabbit.admin.QueueInfo
 
getMessagesUnacknowledged() - Method in class org.springframework.amqp.rabbit.admin.QueueInfo
 
getMessageUncommitted() - Method in class org.springframework.amqp.rabbit.admin.QueueInfo
 
getName() - Method in class org.springframework.amqp.core.AbstractExchange
 
getName() - Method in interface org.springframework.amqp.core.Exchange
 
getName() - Method in class org.springframework.amqp.core.Queue
 
getName() - Method in class org.springframework.amqp.rabbit.admin.QueueInfo
 
getName() - Method in class org.springframework.erlang.core.Node
 
getNodes() - Method in class org.springframework.amqp.rabbit.admin.RabbitStatus
 
getOtpPeer() - Method in class org.springframework.erlang.connection.ConnectionParameters
 
getOtpSelf() - Method in class org.springframework.erlang.connection.ConnectionParameters
 
getOut() - Method in class org.springframework.util.exec.PumpStreamHandler
 
getPhase() - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
 
getPhase() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
Return the phase in which this container will be started and stopped.
getPid() - Method in class org.springframework.amqp.rabbit.admin.QueueInfo
 
getPort() - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactory
 
getPort() - Method in class org.springframework.amqp.rabbit.connection.SingleConnectionFactory
 
getPriority() - Method in class org.springframework.amqp.core.MessageProperties
 
getProcEnvironment() - Static method in class org.springframework.util.exec.Execute
Find the list of environment variables for this process.
getQueue() - Method in class org.springframework.amqp.core.Binding
 
getQueueName() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
Return the name of the queue to receive messages from.
getQueues() - Method in class org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin
 
getQueues(String) - Method in class org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin
 
getQueues() - Method in interface org.springframework.amqp.rabbit.admin.RabbitBrokerOperations
 
getQueues(String) - Method in interface org.springframework.amqp.rabbit.admin.RabbitBrokerOperations
 
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.
getReasonTuple() - Method in exception org.springframework.erlang.ErlangBadRpcException
 
getReasonTuple() - Method in exception org.springframework.erlang.ErlangErrorRpcException
 
getReceivedExchange() - Method in class org.springframework.amqp.core.MessageProperties
 
getReceivedExchange(Message) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter
 
getReceivedRoutingKey() - Method in class org.springframework.amqp.core.MessageProperties
 
getReplyTo() - Method in class org.springframework.amqp.core.MessageProperties
 
getReplyToAddress(Message) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter
Determine a reply-to Address for the given message.
getRequiredQueueName() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
 
getResourceFactory() - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager
 
getRoutingKey() - Method in class org.springframework.amqp.core.Address
 
getRoutingKey() - Method in class org.springframework.amqp.core.Binding
 
getRunningApplications() - Method in class org.springframework.amqp.rabbit.admin.RabbitStatus
 
getRunningNodes() - Method in class org.springframework.amqp.rabbit.admin.RabbitStatus
 
getSharedConnection() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
Return the shared Rabbit Connection maintained by this container.
getSharedConnectionProxy(Connection) - Method in class org.springframework.erlang.connection.SingleConnectionFactory
Wrap the given OtpConnection with a proxy that delegates every method call to it but suppresses close calls.
getStatus() - Method in class org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin
 
getStatus() - Method in interface org.springframework.amqp.rabbit.admin.RabbitBrokerOperations
Returns the status of the node.
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.
getTargetConnection() - Method in interface org.springframework.erlang.connection.ConnectionProxy
 
getTargetConnection() - Method in class org.springframework.erlang.connection.DefaultConnection
 
getTimestamp() - Method in class org.springframework.amqp.core.MessageProperties
 
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.support.RabbitAccessor
 
getTransactions() - Method in class org.springframework.amqp.rabbit.admin.QueueInfo
 
getType() - Method in class org.springframework.amqp.core.AbstractExchange
 
getType() - Method in class org.springframework.amqp.core.DirectExchange
 
getType() - Method in interface org.springframework.amqp.core.Exchange
 
getType() - Method in class org.springframework.amqp.core.FanoutExchange
 
getType() - Method in class org.springframework.amqp.core.HeadersExchange
 
getType() - Method in class org.springframework.amqp.core.MessageProperties
 
getType() - Method in class org.springframework.amqp.core.TopicExchange
 
getUserId() - Method in class org.springframework.amqp.core.MessageProperties
 
getVersion() - Method in class org.springframework.erlang.core.Application
 
getVirtualHost() - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactory
 
getVirtualHost() - Method in class org.springframework.amqp.rabbit.connection.SingleConnectionFactory
 

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.
handleResponseError(String, String, OtpErlangObject) - Method in class org.springframework.erlang.core.ErlangTemplate
 
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.
HEADERS - Static variable in class org.springframework.amqp.core.ExchangeTypes
 
HeadersExchange - Class in org.springframework.amqp.core
 
HeadersExchange(String) - Constructor for class org.springframework.amqp.core.HeadersExchange
 
HeadersExchangeParser - Class in org.springframework.amqp.rabbit.config
 
HeadersExchangeParser() - Constructor for class org.springframework.amqp.rabbit.config.HeadersExchangeParser
 

I

init() - Method in class org.springframework.amqp.rabbit.config.RabbitNamespaceHandler
 
initConnection() - Method in class org.springframework.erlang.connection.SingleConnectionFactory
 
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.listener.AbstractMessageListenerContainer
Initialize this container.
initializeConsumers() - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
 
initializeConverterMap() - Method in class org.springframework.amqp.rabbit.admin.RabbitControlErlangConverter
 
initializeDefaultErlangTemplate() - Method in class org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin
 
initializeJsonObjectMapper() - Method in class org.springframework.amqp.support.converter.JsonMessageConverter
Subclass and override to customize.
initializeProxy() - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
 
INVALID - Static variable in class org.springframework.util.exec.Execute
Invalid exit code.
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.
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.
isAlive() - Method in class org.springframework.amqp.rabbit.admin.RabbitStatus
 
isArch(String) - Static method in class org.springframework.util.exec.Os
Determines if the OS on which Ant is executing matches the given OS architecture.
isAutoAck() - Method in enum org.springframework.amqp.core.AcknowledgeMode
 
isAutoDelete() - Method in class org.springframework.amqp.core.AbstractExchange
 
isAutoDelete() - Method in interface org.springframework.amqp.core.Exchange
 
isAutoDelete() - Method in class org.springframework.amqp.core.Queue
 
isAutoDelete() - Method in class org.springframework.amqp.rabbit.admin.QueueInfo
 
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.support.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
 
isDurable() - Method in class org.springframework.amqp.core.AbstractExchange
 
isDurable() - Method in interface org.springframework.amqp.core.Exchange
 
isDurable() - Method in class org.springframework.amqp.core.Queue
 
isDurable() - Method in class org.springframework.amqp.rabbit.admin.QueueInfo
 
isExclusive() - Method in class org.springframework.amqp.core.Queue
 
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.
isFamily(String) - Static method in class org.springframework.util.exec.Os
Determines if the OS on which Ant is executing matches the given OS family.
isFrozen() - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder
 
isManual() - Method in enum org.springframework.amqp.core.AcknowledgeMode
 
isName(String) - Static method in class org.springframework.util.exec.Os
Determines if the OS on which Ant is executing matches the given OS name.
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
 
isOs(String, String, String, String) - Static method in class org.springframework.util.exec.Os
Determines if the OS on which Ant is executing matches the given OS family, name, architecture and version
isReady() - Method in class org.springframework.amqp.rabbit.admin.RabbitStatus
 
isRedelivered() - Method in class org.springframework.amqp.core.MessageProperties
 
isRunning() - Method in class org.springframework.amqp.rabbit.admin.RabbitStatus
 
isRunning() - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
 
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.
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.
isTransactionAllowed() - Method in enum org.springframework.amqp.core.AcknowledgeMode
 
isUniqueSelfNodeName() - Method in class org.springframework.erlang.connection.SimpleConnectionFactory
 
isUniqueSelfNodeName() - Method in class org.springframework.erlang.connection.SingleConnectionFactory
 
isVersion(String) - Static method in class org.springframework.util.exec.Os
Determines if the OS on which Ant is executing matches the given OS version.
isWatching() - Method in class org.springframework.util.exec.ExecuteWatchdog
Indicates whether or not the watchdog is still monitoring the process.

J

JsonMessageConverter - Class in org.springframework.amqp.support.converter
JSON converter that uses the Jackson Json library.
JsonMessageConverter() - Constructor for class org.springframework.amqp.support.converter.JsonMessageConverter
 

K

kill() - Method in class org.springframework.util.exec.Execute
 
killedProcess() - Method in class org.springframework.util.exec.ExecuteWatchdog
Indicates whether the last process run was killed on timeout or not.

L

ListenerExecutionFailedException - Exception in org.springframework.amqp.rabbit.listener.adapter
Exception to be thrown when the execution of a listener method failed.
ListenerExecutionFailedException(String, Throwable) - Constructor for exception org.springframework.amqp.rabbit.listener.adapter.ListenerExecutionFailedException
Constructor for ListenerExecutionFailedException.
listPermissions() - Method in class org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin
 
listPermissions(String) - Method in class org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin
 
listPermissions() - Method in interface org.springframework.amqp.rabbit.admin.RabbitBrokerOperations
 
listPermissions(String) - Method in interface org.springframework.amqp.rabbit.admin.RabbitBrokerOperations
 
listUserPermissions(String) - Method in class org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin
 
listUserPermissions(String) - Method in interface org.springframework.amqp.rabbit.admin.RabbitBrokerOperations
 
listUsers() - Method in class org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin
 
listUsers() - Method in interface org.springframework.amqp.rabbit.admin.RabbitBrokerOperations
 
logger - Variable in class org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin
Logger available to subclasses
logger - Variable in class org.springframework.amqp.rabbit.admin.RabbitControlErlangConverter
 
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
logger - Variable in class org.springframework.amqp.rabbit.support.RabbitAccessor
Logger available to subclasses
logger - Variable in class org.springframework.erlang.connection.SimpleConnectionFactory
 
logger - Variable in class org.springframework.erlang.connection.SingleConnectionFactory
 
logger - Variable in class org.springframework.erlang.support.ErlangAccessor
Logger available to subclasses

M

main(String[]) - Static method in class org.springframework.util.exec.Background
 
main(String[]) - Static method in class org.springframework.util.exec.Escape
 
MarshallingMessageConverter - Class in org.springframework.amqp.support.converter
Spring Rabbit MessageConverter that uses a Marshaller and Unmarshaller.
MarshallingMessageConverter() - Constructor for class org.springframework.amqp.support.converter.MarshallingMessageConverter
Construct a new MarshallingMessageConverter with no Marshaller or Unmarshaller set.
MarshallingMessageConverter(Marshaller) - Constructor for class org.springframework.amqp.support.converter.MarshallingMessageConverter
Construct a new MarshallingMessageConverter with the given Marshaller set.
MarshallingMessageConverter(Marshaller, Unmarshaller) - Constructor for class org.springframework.amqp.support.converter.MarshallingMessageConverter
Construct a new MarshallingMessageConverter with the given Marshaller and Unmarshaller.
match() - Method in class org.springframework.amqp.core.BindingBuilder.HeadersExchangeMapConfigurer.HeadersExchangeMapBindingCreator
 
matches(Object) - Method in class org.springframework.amqp.core.BindingBuilder.HeadersExchangeMapConfigurer.HeadersExchangeSingleValueBindingCreator
 
Message - Class in org.springframework.amqp.core
The 0-8 and 0-9-1 AMQP specifications do not define an Message class or interface.
Message(byte[], MessageProperties) - Constructor for class org.springframework.amqp.core.Message
 
MessageConversionException - Exception in org.springframework.amqp.support.converter
Exception to be thrown by message converters if they encounter a problem with converting a message or object.
MessageConversionException(String, Throwable) - Constructor for exception org.springframework.amqp.support.converter.MessageConversionException
 
MessageConversionException(String) - Constructor for exception org.springframework.amqp.support.converter.MessageConversionException
 
MessageConverter - Interface in org.springframework.amqp.support.converter
 
MessageDeliveryMode - Enum in org.springframework.amqp.core
Enumeration for the message delivery mode.
MessageListener - Interface in org.springframework.amqp.core
Listener interface to receive asynchronous delivery of Amqp Messages.
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.
MessagePostProcessor - Interface in org.springframework.amqp.core
To be used with the send method of Amqp template classes (such as RabbitTemplate) that convert an object to a message.
MessageProperties - Class in org.springframework.amqp.core
Message Properties for an AMQP message.
MessageProperties() - Constructor for class org.springframework.amqp.core.MessageProperties
 

N

name - Variable in class org.springframework.amqp.core.AbstractExchange
 
NamespaceUtils - Class in org.springframework.amqp.rabbit.config
Shared utility methods for namespace parsers.
NamespaceUtils() - Constructor for class org.springframework.amqp.rabbit.config.NamespaceUtils
 
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.
Node - Class in org.springframework.erlang.core
Simple description class for an Erlang node.
Node(String) - Constructor for class org.springframework.erlang.core.Node
 

O

onMessage(Message) - Method in interface org.springframework.amqp.core.MessageListener
 
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 - package org.springframework.amqp
 
org.springframework.amqp.config - package org.springframework.amqp.config
 
org.springframework.amqp.core - package org.springframework.amqp.core
 
org.springframework.amqp.rabbit.admin - package org.springframework.amqp.rabbit.admin
 
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.support - package org.springframework.amqp.rabbit.support
 
org.springframework.amqp.rabbit.transaction - package org.springframework.amqp.rabbit.transaction
 
org.springframework.amqp.support.converter - package org.springframework.amqp.support.converter
 
org.springframework.amqp.utils - package org.springframework.amqp.utils
 
org.springframework.erlang - package org.springframework.erlang
 
org.springframework.erlang.connection - package org.springframework.erlang.connection
 
org.springframework.erlang.core - package org.springframework.erlang.core
 
org.springframework.erlang.support - package org.springframework.erlang.support
 
org.springframework.erlang.support.converter - package org.springframework.erlang.support.converter
 
org.springframework.util.exec - package org.springframework.util.exec
 
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".
Os - Class in org.springframework.util.exec
Condition that tests the OS type.
Os() - Constructor for class org.springframework.util.exec.Os
 
OtpAuthException - Exception in org.springframework.erlang
Runtime exception mirroring the OTP OtpAuthException.
OtpAuthException(OtpAuthException) - Constructor for exception org.springframework.erlang.OtpAuthException
 
OtpAuthException(String, OtpAuthException) - Constructor for exception org.springframework.erlang.OtpAuthException
 
OtpException - Exception in org.springframework.erlang
Base RuntimeException for errors that occur when executing OTP operations.
OtpException(String) - Constructor for exception org.springframework.erlang.OtpException
 
OtpException(Throwable) - Constructor for exception org.springframework.erlang.OtpException
 
OtpException(String, Throwable) - Constructor for exception org.springframework.erlang.OtpException
 
OtpIOException - Exception in org.springframework.erlang
RuntimeException wrapper for an IOException which can be commonly thrown from OTP operations.
OtpIOException(IOException) - Constructor for exception org.springframework.erlang.OtpIOException
 
OtpIOException(String, IOException) - Constructor for exception org.springframework.erlang.OtpIOException
 

P

parseBinding(BeanMetadataElement, Element, ParserContext) - Method in class org.springframework.amqp.rabbit.config.AbstractExchangeParser
 
parseBinding(BeanMetadataElement, Element, ParserContext) - Method in class org.springframework.amqp.rabbit.config.DirectExchangeParser
 
parseBinding(BeanMetadataElement, Element, ParserContext) - Method in class org.springframework.amqp.rabbit.config.FanoutExchangeParser
 
parseBinding(BeanMetadataElement, Element, ParserContext) - Method in class org.springframework.amqp.rabbit.config.HeadersExchangeParser
 
parseBinding(BeanMetadataElement, 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.
postProcessMessage(Message) - Method in interface org.springframework.amqp.core.MessagePostProcessor
 
postProcessResponse(Message, Message) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter
Post-process the given response message before it will be sent.
prepareConnection(Connection) - Method in class org.springframework.erlang.connection.SingleConnectionFactory
 
prepareSharedConnection(Connection) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
Prepare the given Connection, which is about to be registered as shared Connection for this container.
PumpStreamHandler - Class in org.springframework.util.exec
Copies standard output and error of subprocesses to standard output and error of the parent process.
PumpStreamHandler(OutputStream, OutputStream) - Constructor for class org.springframework.util.exec.PumpStreamHandler
 
PumpStreamHandler(OutputStream) - Constructor for class org.springframework.util.exec.PumpStreamHandler
 
PumpStreamHandler() - Constructor for class org.springframework.util.exec.PumpStreamHandler
 
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
 

Q

queue - Variable in class org.springframework.amqp.core.BindingBuilder.HeadersExchangeMapConfigurer
 
Queue - Class in org.springframework.amqp.core
Simple container collecting information to describe a queue.
Queue(String) - Constructor for class org.springframework.amqp.core.Queue
 
QueueInfo - Class in org.springframework.amqp.rabbit.admin
This class represents a Queue that is configured on the RabbitMQ broker
QueueInfo() - Constructor for class org.springframework.amqp.rabbit.admin.QueueInfo
 
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.support
 
RabbitAccessor() - Constructor for class org.springframework.amqp.rabbit.support.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
 
RabbitAdmin(RabbitTemplate) - Constructor for class org.springframework.amqp.rabbit.core.RabbitAdmin
 
RabbitAdminAuthException - Exception in org.springframework.amqp.rabbit.admin
 
RabbitAdminAuthException(String, OtpAuthException) - Constructor for exception org.springframework.amqp.rabbit.admin.RabbitAdminAuthException
 
RabbitBrokerAdmin - Class in org.springframework.amqp.rabbit.admin
Rabbit broker administration.
RabbitBrokerAdmin() - Constructor for class org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin
 
RabbitBrokerAdmin(String) - Constructor for class org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin
Create an instance by supplying the erlang node name (e.g.
RabbitBrokerAdmin(String, String) - Constructor for class org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin
Create an instance by supplying the erlang node name and cookie (unique string).
RabbitBrokerAdmin(String, int) - Constructor for class org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin
Create an instance by supplying the erlang node name and port number.
RabbitBrokerAdmin(String, int, String) - Constructor for class org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin
Create an instance by supplying the erlang node name, port number and cookie (unique string).
RabbitBrokerOperations - Interface in org.springframework.amqp.rabbit.admin
Performs administration tasks for RabbitMQ broker administration.
RabbitControlErlangConverter - Class in org.springframework.amqp.rabbit.admin
Converter that understands the responses from the rabbit control module and related functionality.
RabbitControlErlangConverter(Map<String, String>) - Constructor for class org.springframework.amqp.rabbit.admin.RabbitControlErlangConverter
 
RabbitControlErlangConverter.ListUsersConverter - Class in org.springframework.amqp.rabbit.admin
 
RabbitControlErlangConverter.ListUsersConverter() - Constructor for class org.springframework.amqp.rabbit.admin.RabbitControlErlangConverter.ListUsersConverter
 
RabbitControlErlangConverter.QueueInfoAllConverter - Class in org.springframework.amqp.rabbit.admin
 
RabbitControlErlangConverter.QueueInfoAllConverter() - Constructor for class org.springframework.amqp.rabbit.admin.RabbitControlErlangConverter.QueueInfoAllConverter
 
RabbitControlErlangConverter.QueueInfoField - Enum in org.springframework.amqp.rabbit.admin
 
RabbitControlErlangConverter.StatusConverter - Class in org.springframework.amqp.rabbit.admin
 
RabbitControlErlangConverter.StatusConverter() - Constructor for class org.springframework.amqp.rabbit.admin.RabbitControlErlangConverter.StatusConverter
 
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
 
RabbitStatus - Class in org.springframework.amqp.rabbit.admin
The status object returned from querying the broker
RabbitStatus(List<Application>, List<Node>, List<Node>) - Constructor for class org.springframework.amqp.rabbit.admin.RabbitStatus
 
rabbitTemplate() - Method in class org.springframework.amqp.rabbit.config.AbstractRabbitConfiguration
Create a bean definition for RabbitTemplate.
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.support
 
RabbitUtils() - Constructor for class org.springframework.amqp.rabbit.support.RabbitUtils
 
receive() - Method in interface org.springframework.amqp.core.AmqpTemplate
 
receive(String) - Method in interface org.springframework.amqp.core.AmqpTemplate
 
receive() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
 
receive(String) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
 
receiveAndConvert() - Method in interface org.springframework.amqp.core.AmqpTemplate
 
receiveAndConvert(String) - Method in interface org.springframework.amqp.core.AmqpTemplate
 
receiveAndConvert() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
 
receiveAndConvert(String) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
 
receiveAndExecute(BlockingQueueConsumer) - Method in interface org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.ContainerDelegate
 
receiveRPC() - Method in interface org.springframework.erlang.connection.Connection
Receive an RPC reply from the remote Erlang node.
receiveRPC() - Method in class org.springframework.erlang.connection.DefaultConnection
 
recoverAsync(boolean) - Method in class org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin
 
recoverAsync(boolean) - Method in interface org.springframework.amqp.rabbit.admin.RabbitBrokerOperations
 
refreshSharedConnection() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
Refresh the shared Connection that this container holds.
registerConverter(String, String, ErlangConverter) - Method in class org.springframework.amqp.rabbit.admin.RabbitControlErlangConverter
 
registerDeliveryTag(ConnectionFactory, Channel, Long) - Static method in class org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils
 
releaseConnection(Connection) - Static method in class org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils
Release the given Connection by closing it.
releaseConnection(Connection, ConnectionFactory) - Static method in class org.springframework.erlang.connection.ConnectionFactoryUtils
Release the given Connection by closing it.
releaseConnection(OtpConnection) - Static method in class org.springframework.erlang.support.ErlangUtils
Close the given Connection.
releaseResources(RabbitResourceHolder) - Static method in class org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils
 
removeBinding(Binding) - Method in interface org.springframework.amqp.core.AmqpAdmin
Remove a binding of a queue to an exchange.
removeBinding(Binding) - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
 
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.connection.SingleConnectionFactory
Default implementation does nothing.
resetConnection() - Method in class org.springframework.erlang.connection.SingleConnectionFactory
Reset the underlying shared Connection, to be reinitialized on next access.
resetNode() - Method in class org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin
 
resetNode() - Method in interface org.springframework.amqp.rabbit.admin.RabbitBrokerOperations
Removes the node from any cluster it belongs to, removes all data from the management database, such as configured users and vhosts, and deletes all persistent messages.
rollbackAll() - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder
 
rollbackIfNecessary(Channel) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
Perform a rollback, if appropriate.
rollbackIfNecessary(Channel) - Static method in class org.springframework.amqp.rabbit.support.RabbitUtils
 
rollbackOnExceptionIfNecessary(Channel, Message, Throwable) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
Perform a rollback, handling rollback exceptions properly.
run() - Method in class org.springframework.util.exec.ExecuteWatchdog
Watches the process and terminates it, if it runs for too long.
run() - Method in class org.springframework.util.exec.StreamPumper
Copies data from the input stream to the output stream.

S

send(Message) - Method in interface org.springframework.amqp.core.AmqpTemplate
 
send(String, Message) - Method in interface org.springframework.amqp.core.AmqpTemplate
 
send(String, String, Message) - Method in interface org.springframework.amqp.core.AmqpTemplate
 
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 interface org.springframework.amqp.core.AmqpTemplate
 
sendAndReceive(String, Message) - Method in interface org.springframework.amqp.core.AmqpTemplate
 
sendAndReceive(String, String, Message) - Method in interface org.springframework.amqp.core.AmqpTemplate
 
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.
sendRPC(String, String, OtpErlangList) - Method in interface org.springframework.erlang.connection.Connection
Send an RPC request to the remote Erlang node.
sendRPC(String, String, OtpErlangList) - Method in class org.springframework.erlang.connection.DefaultConnection
 
SerializationUtils - Class in org.springframework.amqp.utils
Static utility to help with serialization.
SerializationUtils() - Constructor for class org.springframework.amqp.utils.SerializationUtils
 
serialize(Object) - Static method in class org.springframework.amqp.utils.SerializationUtils
Serialize the object provided.
SerializerMessageConverter - Class in org.springframework.amqp.support.converter
Implementation of MessageConverter that can work with Strings or native objects of any kind via the Serializer and Deserializer abstractions in Spring.
SerializerMessageConverter() - Constructor for class org.springframework.amqp.support.converter.SerializerMessageConverter
 
setAcknowledgeMode(AcknowledgeMode) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
Flag controlling the behaviour of the container with respect to message acknowledgement.
setAcksUncommitted(long) - Method in class org.springframework.amqp.rabbit.admin.QueueInfo
 
setAdviceChain(Advice[]) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
Public setter for the Advice to apply to listener executions.
setAppId(String) - Method in class org.springframework.amqp.core.MessageProperties
 
setApplicationContext(ApplicationContext) - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
 
setArguments(Map<String, Object>) - Method in class org.springframework.amqp.core.AbstractExchange
Set the collection of arbitrary arguments to use when declaring an exchange.
setArguments(Map<String, Object>) - Method in class org.springframework.amqp.core.Binding
 
setArguments(Map<String, Object>) - Method in class org.springframework.amqp.core.Queue
 
setArguments(String[]) - Method in class org.springframework.amqp.rabbit.admin.QueueInfo
 
setAutoDelete(boolean) - Method in class org.springframework.amqp.core.AbstractExchange
Set the auto-delete lifecycle of this exchange.
setAutoDelete(boolean) - Method in class org.springframework.amqp.core.Queue
 
setAutoDelete(boolean) - Method in class org.springframework.amqp.rabbit.admin.QueueInfo
 
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.
setBeanClassLoader(ClassLoader) - Method in class org.springframework.amqp.support.converter.SimpleMessageConverter
 
setBeanName(String) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
 
setChannelCacheSize(int) - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
 
setChannelTransacted(boolean) - Method in class org.springframework.amqp.rabbit.support.RabbitAccessor
Flag to indicate that channels created by this component will be transactional.
setClassMapper(ClassMapper) - Method in class org.springframework.amqp.support.converter.JsonMessageConverter
 
setClusterId(String) - Method in class org.springframework.amqp.core.MessageProperties
 
setCodebaseUrl(String) - Method in class org.springframework.amqp.support.converter.SimpleMessageConverter
Set the codebase URL to download classes from if not found locally.
setCommandline(String[]) - Method in class org.springframework.util.exec.Execute
Sets the commandline of the subprocess to launch.
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.core.support.RabbitGatewaySupport
Set the Rabbit connection factory to be used by the gateway.
setConnectionFactory(ConnectionFactory) - Method in class org.springframework.amqp.rabbit.support.RabbitAccessor
Set the ConnectionFactory to use for obtaining RabbitMQ Connections.
setConnectionFactory(ConnectionFactory) - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager
 
setConnectionFactory(ConnectionFactory) - Method in class org.springframework.erlang.support.ErlangAccessor
 
setConsumers(long) - Method in class org.springframework.amqp.rabbit.admin.QueueInfo
 
setContentEncoding(String) - Method in class org.springframework.amqp.core.MessageProperties
 
setContentLength(long) - Method in class org.springframework.amqp.core.MessageProperties
 
setContentType(String) - Method in class org.springframework.amqp.core.MessageProperties
 
setCorrelationId(byte[]) - Method in class org.springframework.amqp.core.MessageProperties
 
setDefaultCharset(String) - Method in class org.springframework.amqp.support.converter.JsonMessageConverter
Specify the default charset to use when converting to or from text-based Message body content.
setDefaultCharset(String) - Method in class org.springframework.amqp.support.converter.SerializerMessageConverter
Specify the default charset to use when converting to or from text-based Message body content.
setDefaultCharset(String) - Method in class org.springframework.amqp.support.converter.SimpleMessageConverter
Specify the default charset to use when converting to or from text-based Message body content.
setDefaultHashtableClass(Class<?>) - Method in class org.springframework.amqp.support.converter.DefaultClassMapper
 
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.
setDeliveryMode(MessageDeliveryMode) - Method in class org.springframework.amqp.core.MessageProperties
 
setDeliveryTag(long) - Method in class org.springframework.amqp.core.MessageProperties
 
setDeserializer(Deserializer<Object>) - Method in class org.springframework.amqp.support.converter.SerializerMessageConverter
The deserializer to use for converting from message body to Java object.
setDontkill(boolean) - Method in class org.springframework.util.exec.ExecuteWatchdog
 
setDurable(boolean) - Method in class org.springframework.amqp.core.AbstractExchange
Set the durability of this exchange definition.
setDurable(boolean) - Method in class org.springframework.amqp.core.Queue
 
setDurable(boolean) - Method in class org.springframework.amqp.rabbit.admin.QueueInfo
 
setEncoding(String) - Method in class org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin
The encoding to use for converting host names to byte arrays (which is needed on the remote side).
setEnvironment(String[]) - Method in class org.springframework.util.exec.Execute
Sets the environment variables for the subprocess to launch.
setErlangConverter(ErlangConverter) - Method in class org.springframework.erlang.core.ErlangTemplate
 
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.core.RabbitTemplate
 
setExclusive(boolean) - Method in class org.springframework.amqp.core.Queue
 
setExitValue(int) - Method in class org.springframework.util.exec.Execute
 
setExpiration(String) - Method in class org.springframework.amqp.core.MessageProperties
 
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.
setHeader(String, Object) - Method in class org.springframework.amqp.core.MessageProperties
 
setHost(String) - Method in class org.springframework.amqp.rabbit.connection.SingleConnectionFactory
 
setIdClassMapping(Map<String, Class<?>>) - Method in class org.springframework.amqp.support.converter.DefaultClassMapper
 
setIgnoreContentType(boolean) - Method in class org.springframework.amqp.support.converter.SerializerMessageConverter
Flag to signal that the content type should be ignored and the deserializer used irrespective if it is a text message.
setImmediatePublish(boolean) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter
 
setMandatoryPublish(boolean) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter
 
setMarshaller(Marshaller) - Method in class org.springframework.amqp.support.converter.MarshallingMessageConverter
Set the Marshaller to be used by this message converter.
setMemory(long) - Method in class org.springframework.amqp.rabbit.admin.QueueInfo
 
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.
setMessageCount(Integer) - Method in class org.springframework.amqp.core.MessageProperties
 
setMessageId(String) - Method in class org.springframework.amqp.core.MessageProperties
 
setMessageListener(Object) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
Set the message listener implementation to register.
setMessages(long) - Method in class org.springframework.amqp.rabbit.admin.QueueInfo
 
setMessagesReady(long) - Method in class org.springframework.amqp.rabbit.admin.QueueInfo
 
setMessagesUnacknowledged(long) - Method in class org.springframework.amqp.rabbit.admin.QueueInfo
 
setMessageUncommitted(long) - Method in class org.springframework.amqp.rabbit.admin.QueueInfo
 
setModuleAdapter(Map<String, String>) - Method in class org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin
Allows users to adapt Erlang RPC (module, function) pairs to older, or different, versions of the broker than the current target.
setName(String) - Method in class org.springframework.amqp.rabbit.admin.QueueInfo
 
setNewenvironment(boolean) - Method in class org.springframework.util.exec.Execute
Set whether to propagate the default environment or not.
setPassword(String) - Method in class org.springframework.amqp.rabbit.connection.SingleConnectionFactory
 
setPermissions(String, Pattern, Pattern, Pattern) - Method in class org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin
 
setPermissions(String, Pattern, Pattern, Pattern, String) - Method in class org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin
 
setPermissions(String, Pattern, Pattern, Pattern) - Method in interface org.springframework.amqp.rabbit.admin.RabbitBrokerOperations
 
setPermissions(String, Pattern, Pattern, Pattern, String) - Method in interface org.springframework.amqp.rabbit.admin.RabbitBrokerOperations
 
setPhase(int) - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
 
setPhase(int) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
Specify the phase in which this container should be started and stopped.
setPid(String) - Method in class org.springframework.amqp.rabbit.admin.QueueInfo
 
setPort(int) - Method in class org.springframework.amqp.rabbit.connection.SingleConnectionFactory
 
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.
setPriority(Integer) - Method in class org.springframework.amqp.core.MessageProperties
 
setProcessErrorStream(InputStream) - Method in interface org.springframework.util.exec.ExecuteStreamHandler
Install a handler for the error stream of the subprocess.
setProcessErrorStream(InputStream) - Method in class org.springframework.util.exec.PumpStreamHandler
 
setProcessInputStream(OutputStream) - Method in interface org.springframework.util.exec.ExecuteStreamHandler
Install a handler for the input stream of the subprocess.
setProcessInputStream(OutputStream) - Method in class org.springframework.util.exec.PumpStreamHandler
 
setProcessOutputStream(InputStream) - Method in interface org.springframework.util.exec.ExecuteStreamHandler
Install a handler for the output stream of the subprocess.
setProcessOutputStream(InputStream) - Method in class org.springframework.util.exec.PumpStreamHandler
 
setQueue(String) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
 
setQueueName(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
 
setRabbitLogBaseDirectory(String) - Method in class org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin
The location of RABBITMQ_LOG_BASE to override the system default (which may be owned by another user).
setRabbitMnesiaBaseDirectory(String) - Method in class org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin
The location of RABBITMQ_MNESIA_BASE to override the system default (which may be owned by another user).
setRabbitTemplate(RabbitTemplate) - Method in class org.springframework.amqp.rabbit.core.support.RabbitGatewaySupport
Set the RabbitTemplate for the gateway.
setReceivedExchange(String) - Method in class org.springframework.amqp.core.MessageProperties
 
setReceivedRoutingKey(String) - Method in class org.springframework.amqp.core.MessageProperties
 
setReceiveTimeout(long) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
 
setRedelivered(Boolean) - Method in class org.springframework.amqp.core.MessageProperties
 
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.
setReplyTo(Address) - Method in class org.springframework.amqp.core.MessageProperties
 
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.
setRoutingKey(String) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
 
setSerializer(Serializer<Object>) - Method in class org.springframework.amqp.support.converter.SerializerMessageConverter
The serializer to use for converting Java objects to message bodies.
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.
setStartupTimeout(long) - Method in class org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin
Timeout (milliseconds) to wait for the broker to come up.
setTaskExecutor(Executor) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
 
setTimestamp(Date) - Method in class org.springframework.amqp.core.MessageProperties
 
setTransactionAttribute(TransactionAttribute) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
 
setTransactionManager(PlatformTransactionManager) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
 
setTransactions(long) - Method in class org.springframework.amqp.rabbit.admin.QueueInfo
 
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).
setType(String) - Method in class org.springframework.amqp.core.MessageProperties
 
setUniqueSelfNodeName(boolean) - Method in class org.springframework.erlang.connection.SimpleConnectionFactory
 
setUniqueSelfNodeName(boolean) - Method in class org.springframework.erlang.connection.SingleConnectionFactory
 
setUnmarshaller(Unmarshaller) - Method in class org.springframework.amqp.support.converter.MarshallingMessageConverter
Set the Unmarshaller to be used by this message converter.
setUserId(String) - Method in class org.springframework.amqp.core.MessageProperties
 
setUsername(String) - Method in class org.springframework.amqp.rabbit.connection.SingleConnectionFactory
 
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.SingleConnectionFactory
 
setWorkingDirectory(File) - Method in class org.springframework.util.exec.Execute
Sets the working directory of the process to execute.
sharedConnectionEnabled() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
Return whether a shared Rabbit Connection should be maintained by this container base class.
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
 
SimpleConnectionFactory - Class in org.springframework.erlang.connection
A simple implementation of ConnectionFactory that return a new connection for each invocation of the createConnection method.
SimpleConnectionFactory(String, String, String) - Constructor for class org.springframework.erlang.connection.SimpleConnectionFactory
 
SimpleConnectionFactory(String, String) - Constructor for class org.springframework.erlang.connection.SimpleConnectionFactory
 
SimpleErlangConverter - Class in org.springframework.erlang.support.converter
Converter that supports the basic types and arrays.
SimpleErlangConverter() - Constructor for class org.springframework.erlang.support.converter.SimpleErlangConverter
 
SimpleMessageConverter - Class in org.springframework.amqp.support.converter
Implementation of MessageConverter that can work with Strings, Serializable instances, or byte arrays.
SimpleMessageConverter() - Constructor for class org.springframework.amqp.support.converter.SimpleMessageConverter
 
SimpleMessageListenerContainer - Class in org.springframework.amqp.rabbit.listener
 
SimpleMessageListenerContainer() - Constructor for class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
 
SimpleMessageListenerContainer(ConnectionFactory) - Constructor for class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
 
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(String) - 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.
SingleConnectionFactory - Class in org.springframework.erlang.connection
A ConnectionFactory implementation that returns the same Connections from all SingleConnectionFactory.createConnection() calls, and ignores calls to Connection.close().
SingleConnectionFactory(String, String, String) - Constructor for class org.springframework.erlang.connection.SingleConnectionFactory
 
SingleConnectionFactory(String, String) - Constructor for class org.springframework.erlang.connection.SingleConnectionFactory
 
start() - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
 
start() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
Start this container.
start() - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer
 
start() - Method in interface org.springframework.util.exec.ExecuteStreamHandler
Start handling of the streams.
start(Process, Thread) - Method in class org.springframework.util.exec.ExecuteWatchdog
Watches the given process and terminates it, if it runs for too long.
start() - Method in class org.springframework.util.exec.PumpStreamHandler
 
startBrokerApplication() - Method in class org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin
 
startBrokerApplication() - Method in interface org.springframework.amqp.rabbit.admin.RabbitBrokerOperations
Starts the RabbitMQ application on an already running node.
startNode() - Method in class org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin
 
startNode() - Method in interface org.springframework.amqp.rabbit.admin.RabbitBrokerOperations
Starts the Erlang node where RabbitMQ is running by shelling out to the directory specified by RABBITMQ_HOME and executing the standard named start script.
stop() - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
 
stop(Runnable) - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
 
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
 
stop() - Method in interface org.springframework.util.exec.ExecuteStreamHandler
Stop handling of the streams - will not be restarted.
stop() - Method in class org.springframework.util.exec.ExecuteWatchdog
Stops the watcher.
stop() - Method in class org.springframework.util.exec.PumpStreamHandler
 
stopBrokerApplication() - Method in class org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin
 
stopBrokerApplication() - Method in interface org.springframework.amqp.rabbit.admin.RabbitBrokerOperations
Stops the RabbitMQ application, leaving the Erlang node running.
stopNode() - Method in class org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin
 
stopNode() - Method in interface org.springframework.amqp.rabbit.admin.RabbitBrokerOperations
Stops the halts the Erlang node on which RabbitMQ is running.
stopSharedConnection() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
Stop the shared Connection, logging any exception thrown by Rabbit API methods.
StreamPumper - Class in org.springframework.util.exec
Copies all data from an input stream to an output stream.
StreamPumper(InputStream, OutputStream) - Constructor for class org.springframework.util.exec.StreamPumper
Create a new stream pumper.
SYSTEM - Static variable in class org.springframework.amqp.core.ExchangeTypes
 

T

to(FanoutExchange) - Method in class org.springframework.amqp.core.BindingBuilder.ExchangeConfigurer
 
to(HeadersExchange) - Method in class org.springframework.amqp.core.BindingBuilder.ExchangeConfigurer
 
to(DirectExchange) - Method in class org.springframework.amqp.core.BindingBuilder.ExchangeConfigurer
 
to(TopicExchange) - Method in class org.springframework.amqp.core.BindingBuilder.ExchangeConfigurer
 
toClass(MessageProperties) - Method in interface org.springframework.amqp.support.converter.ClassMapper
 
toClass(MessageProperties) - Method in class org.springframework.amqp.support.converter.DefaultClassMapper
 
toErlang(Object) - Method in interface org.springframework.erlang.support.converter.ErlangConverter
Convert a Java object to a Erlang data type.
toErlang(Object) - Method in class org.springframework.erlang.support.converter.SimpleErlangConverter
 
toInt(MessageDeliveryMode) - Static method in enum org.springframework.amqp.core.MessageDeliveryMode
 
toMessage(Object, MessageProperties) - Method in class org.springframework.amqp.support.converter.JsonMessageConverter
 
toMessage(Object, MessageProperties) - Method in class org.springframework.amqp.support.converter.MarshallingMessageConverter
Marshals the given object to a Message.
toMessage(Object, MessageProperties) - Method in interface org.springframework.amqp.support.converter.MessageConverter
Convert a Java object to a Rabbit Message.
toMessage(Object, MessageProperties) - Method in class org.springframework.amqp.support.converter.SerializerMessageConverter
Creates an AMQP Message from the provided Object.
toMessage(Object, MessageProperties) - Method in class org.springframework.amqp.support.converter.SimpleMessageConverter
Creates an AMQP Message from the provided Object.
TOPIC - Static variable in class org.springframework.amqp.core.ExchangeTypes
 
TopicExchange - Class in org.springframework.amqp.core
Simple container collecting information to describe a topic exchange.
TopicExchange(String) - Constructor for class org.springframework.amqp.core.TopicExchange
 
TopicExchange(String, boolean, boolean) - Constructor for class org.springframework.amqp.core.TopicExchange
 
TopicExchangeParser - Class in org.springframework.amqp.rabbit.config
 
TopicExchangeParser() - Constructor for class org.springframework.amqp.rabbit.config.TopicExchangeParser
 
toQueueInfoField(String) - Static method in enum org.springframework.amqp.rabbit.admin.RabbitControlErlangConverter.QueueInfoField
 
toString() - Method in class org.springframework.amqp.core.AbstractExchange
 
toString() - Method in class org.springframework.amqp.core.Address
 
toString() - Method in class org.springframework.amqp.core.Message
 
toString() - Method in class org.springframework.amqp.core.Queue
 
toString() - Method in class org.springframework.amqp.rabbit.admin.QueueInfo
 
toString() - Method in class org.springframework.amqp.rabbit.admin.RabbitStatus
 
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
 
toString() - Method in class org.springframework.erlang.core.Application
 
toString() - Method in class org.springframework.erlang.core.Node
 

U

UncategorizedAmqpException - Exception in org.springframework.amqp
A "catch-all" exception type within the AmqpException hierarchy when no more specific cause is known.
UncategorizedAmqpException(Throwable) - Constructor for exception org.springframework.amqp.UncategorizedAmqpException
 
UncategorizedAmqpException(String, Throwable) - Constructor for exception org.springframework.amqp.UncategorizedAmqpException
 
UncategorizedOtpException - Exception in org.springframework.erlang
A "catch-all" exception type within the OtpException hierarchy when no more specific cause is known.
UncategorizedOtpException(Throwable) - Constructor for exception org.springframework.erlang.UncategorizedOtpException
 
UncategorizedOtpException(String, Throwable) - Constructor for exception org.springframework.erlang.UncategorizedOtpException
 
UniquelyNamedQueue - Class in org.springframework.amqp.core
Create a queue with a unique name.
UniquelyNamedQueue() - Constructor for class org.springframework.amqp.core.UniquelyNamedQueue
Create a uniquely named queue.
UniquelyNamedQueue(String) - Constructor for class org.springframework.amqp.core.UniquelyNamedQueue
Create a uniquely named queue with a fixed prefix.

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.
valueOf(String) - Static method in enum org.springframework.amqp.core.AcknowledgeMode
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.springframework.amqp.core.MessageDeliveryMode
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.springframework.amqp.rabbit.admin.RabbitControlErlangConverter.QueueInfoField
Returns the enum constant of this type with the specified name.
values() - Static method in enum org.springframework.amqp.core.AcknowledgeMode
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.springframework.amqp.core.MessageDeliveryMode
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.springframework.amqp.rabbit.admin.RabbitControlErlangConverter.QueueInfoField
Returns an array containing the constants of this enum type, in the order they are declared.

W

waitFor(Process) - Method in class org.springframework.util.exec.Execute
 
where(String) - Method in class org.springframework.amqp.core.BindingBuilder.HeadersExchangeMapConfigurer
 
whereAll(String...) - Method in class org.springframework.amqp.core.BindingBuilder.HeadersExchangeMapConfigurer
 
whereAll(Map<String, Object>) - Method in class org.springframework.amqp.core.BindingBuilder.HeadersExchangeMapConfigurer
 
whereAny(String...) - Method in class org.springframework.amqp.core.BindingBuilder.HeadersExchangeMapConfigurer
 
whereAny(Map<String, Object>) - Method in class org.springframework.amqp.core.BindingBuilder.HeadersExchangeMapConfigurer
 
with(String) - Method in class org.springframework.amqp.core.BindingBuilder.DirectExchangeRoutingKeyConfigurer
 
with(Enum<?>) - Method in class org.springframework.amqp.core.BindingBuilder.DirectExchangeRoutingKeyConfigurer
 
with(String) - Method in class org.springframework.amqp.core.BindingBuilder.TopicExchangeRoutingKeyConfigurer
 
with(Enum<?>) - Method in class org.springframework.amqp.core.BindingBuilder.TopicExchangeRoutingKeyConfigurer
 
withQueueName() - Method in class org.springframework.amqp.core.BindingBuilder.DirectExchangeRoutingKeyConfigurer
 
wrapToListenerExecutionFailedExceptionIfNeeded(Exception) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
 

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

Copyright © 2011. All Rights Reserved.