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.
AbstractMessageListenerContainer - Class in org.springframework.amqp.rabbit.listener
 
AbstractMessageListenerContainer() - Constructor for class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
 
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
 
AbstractRabbitListeningContainer - Class in org.springframework.amqp.rabbit.listener
 
AbstractRabbitListeningContainer() - Constructor for class org.springframework.amqp.rabbit.listener.AbstractRabbitListeningContainer
 
AbstractRabbitListeningContainer.SharedConnectionNotInitializedException - Exception in org.springframework.amqp.rabbit.listener
Exception that indicates that the initial setup of this container's shared Rabbit Connection failed.
AbstractRabbitListeningContainer.SharedConnectionNotInitializedException(String) - Constructor for exception org.springframework.amqp.rabbit.listener.AbstractRabbitListeningContainer.SharedConnectionNotInitializedException
Create a new SharedConnectionNotInitializedException.
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
 
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.AbstractRabbitListeningContainer
Delegates to AbstractRabbitListeningContainer.validateConfiguration() and AbstractRabbitListeningContainer.initialize().
afterPropertiesSet() - 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.
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
 
afterTestClass(TestContext) - Method in class org.springframework.amqp.rabbit.test.RabbitTestExecutionListener
 
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
 
beforeTestClass(TestContext) - Method in class org.springframework.amqp.rabbit.test.RabbitTestExecutionListener
 
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, String) - Constructor for class org.springframework.amqp.core.Binding
 
Binding(Queue, TopicExchange, String) - Constructor for class org.springframework.amqp.core.Binding
 
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) - Constructor for class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer
 
BlockingQueueConsumer(Channel, BlockingQueue<BlockingQueueConsumer.Delivery>) - Constructor for class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer
 
BlockingQueueConsumer.Delivery - Class in org.springframework.amqp.rabbit.listener
Encapsulates an arbitrary message - simple "bean" holder structure.
BlockingQueueConsumer.Delivery(Envelope, AMQP.BasicProperties, byte[]) - Constructor for class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer.Delivery
 
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) - Method in class org.springframework.amqp.rabbit.connection.SingleConnectionFactory
Close the given Connection.
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.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(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
 
createChannel(Connection) - Method in class org.springframework.amqp.rabbit.support.RabbitAccessor
Create a RabbitMQ Channel for the given Connection.
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.AbstractRabbitListeningContainer
Create a shared Connection for this container.
createTestContextManager(Class<?>) - Method in class org.springframework.amqp.rabbit.test.SpringRabbitJUnit4ClassRunner
Creates a new TestContextManager for the supplied test class and the configured default ContextLoader class name.

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.admin.RabbitBrokerAdmin
 
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.admin.RabbitBrokerAdmin
 
declareExchange(String, String, boolean, boolean) - Method in class org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin
Declare an exchange specifying its durability and auto-delete behavior.
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() - Method in class org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin
 
declareQueue(Queue) - Method in class org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin
 
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.admin.RabbitBrokerAdmin
 
deleteExchange(String, boolean) - Method in class org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin
 
deleteExchange(String, boolean) - Method in interface org.springframework.amqp.rabbit.admin.RabbitBrokerOperations
 
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.admin.RabbitBrokerAdmin
 
deleteQueue(String, boolean, boolean) - Method in class org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin
 
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.AbstractRabbitListeningContainer
Calls AbstractRabbitListeningContainer.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
 
DIRECT_EXCHANGE_ELEMENT - Static variable in class org.springframework.amqp.rabbit.config.RabbitAdminParser
 
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
 
doBegin(Object, TransactionDefinition) - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager
 
doCleanupAfterCompletion(Object) - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager
 
doCommit(DefaultTransactionStatus) - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager
 
doCreateConnection() - Method in class org.springframework.amqp.rabbit.connection.SingleConnectionFactory
Create a Rabbit Connection via this class's ConnectionFactory.
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.AbstractRabbitListeningContainer
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.
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.AbstractRabbitListeningContainer
Close the registered invokers.
doShutdown() - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
 
doStart() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListeningContainer
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.AbstractRabbitListeningContainer
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.AbstractRabbitListeningContainer
Establish a shared Connection for this container.
exchange - Variable in class org.springframework.amqp.core.BindingBuilder.HeadersExchangeMapConfigurer
 
Exchange - Interface in org.springframework.amqp.core
 
EXCHANGES_ELEMENT - Static variable in class org.springframework.amqp.rabbit.config.RabbitAdminParser
 
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
 
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<?>) - Method in interface org.springframework.amqp.support.converter.ClassMapper
 
fromClass(Class<?>) - 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
 
getAcksUncommitted() - Method in class org.springframework.amqp.rabbit.admin.QueueInfo
 
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
 
getBeanName() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListeningContainer
Return the bean name that this listener container has been assigned in its containing bean factory, if any.
getBlockingQueueConsumerCapacity() - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
 
getBody() - Method in class org.springframework.amqp.core.Message
 
getBody() - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer.Delivery
Retrieve the message body.
getCachedChannelProxy(Connection, LinkedList<ChannelProxy>, boolean) - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
 
getChannel(Connection, boolean) - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
 
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(Connection, boolean) - Method in class org.springframework.amqp.rabbit.connection.SingleConnectionFactory
 
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 interface org.springframework.amqp.support.converter.ClassMapper
 
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
 
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
 
getEnvelope() - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer.Delivery
Retrieve the message envelope.
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
 
getErlangTemplate() - Method in class org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin
 
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.AbstractRabbitListeningContainer
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 class org.springframework.amqp.rabbit.connection.SingleConnectionFactory
 
getPrefetchCount() - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
 
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.
getProperties() - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer.Delivery
Retrieve the message properties.
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() - 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.AbstractRabbitListeningContainer
Return the shared Rabbit Connection maintained by this container.
getSharedConnectionProxy(Connection) - Method in class org.springframework.amqp.rabbit.connection.SingleConnectionFactory
Wrap the given Connection with a proxy that delegates every method call to it but suppresses close calls.
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.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
 
getTxSize() - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
 
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

handleDelivery(String, Envelope, AMQP.BasicProperties, byte[]) - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer
 
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.
handleShutdownSignal(String, ShutdownSignalException) - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer
 
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
 

I

init() - Method in class org.springframework.amqp.rabbit.config.RabbitNamespaceHandler
 
initConnection() - Method in class org.springframework.amqp.rabbit.connection.SingleConnectionFactory
 
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.AbstractRabbitListeningContainer
Initialize this container.
initializeConsumers() - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
 
initializeConverterMap() - Method in class org.springframework.amqp.rabbit.admin.RabbitControlErlangConverter
 
initializeDefaultErlangTemplate(RabbitTemplate) - Method in class org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin
 
initializeJsonObjectMapper() - Method in class org.springframework.amqp.support.converter.JsonMessageConverter
Subclass and override to customize.
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.AbstractRabbitListeningContainer
Return whether this container is currently active, that is, whether it has been set up but not shut down yet.
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.
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.AbstractRabbitListeningContainer
 
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
Return whether the RabbitMQ channels used by this accessor are supposed to be transacted.
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
 
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.
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
isRedelivered() - Method in class org.springframework.amqp.core.MessageProperties
 
isRunning() - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
 
isRunning() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListeningContainer
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.
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.connection.SingleConnectionFactory
 
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
 
nextDelivery() - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer
Main application-side API: wait for the next message delivery and return it.
nextDelivery(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 SessionAwareMessageListener 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.test - package org.springframework.amqp.rabbit.test
 
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

parseInnerHandlerDefinition(Element, ParserContext) - Static method in class org.springframework.amqp.rabbit.config.NamespaceUtils
 
parseInternal(Element, ParserContext) - Method in class org.springframework.amqp.rabbit.config.RabbitAdminParser
 
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.amqp.rabbit.connection.SingleConnectionFactory
 
prepareConnection(Connection) - Method in class org.springframework.erlang.connection.SingleConnectionFactory
 
prepareSharedConnection(Connection) - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListeningContainer
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.admin.RabbitBrokerAdmin
 
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
 

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
 
RabbitAdminParser - Class in org.springframework.amqp.rabbit.config
Start of implementation for a potential XML based broker administration schema.
RabbitAdminParser() - Constructor for class org.springframework.amqp.rabbit.config.RabbitAdminParser
 
RabbitBrokerAdmin - Class in org.springframework.amqp.rabbit.admin
Rabbit broker administration implementation exposed via JMX annotations.
RabbitBrokerAdmin(ConnectionFactory) - Constructor for class org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin
 
RabbitBrokerOperations - Interface in org.springframework.amqp.rabbit.admin
Performs administration tasks for RabbitMQ broker administration.
RabbitConfiguration - Annotation Type in org.springframework.amqp.rabbit.test
RabbitConfiguration defines class-level metadata for configuring Rabbit integration tests.
RabbitControlErlangConverter - Class in org.springframework.amqp.rabbit.admin
Converter that understands the responses from the rabbit control module and related functionality.
RabbitControlErlangConverter() - 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
Start of 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
 
RabbitTestExecutionListener - Class in org.springframework.amqp.rabbit.test
A TestExeuctionListener that will start/reset the RabbitMQ node before the methods in the TestClass are executed.
RabbitTestExecutionListener() - Constructor for class org.springframework.amqp.rabbit.test.RabbitTestExecutionListener
 
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
 
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.AbstractRabbitListeningContainer
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 class org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin
 
removeBinding(Binding) - Method in interface org.springframework.amqp.rabbit.admin.RabbitBrokerOperations
 
resetConnection() - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
Reset the Channel cache and underlying shared Connection, to be reinitialized on next access.
resetConnection() - Method in class org.springframework.amqp.rabbit.connection.SingleConnectionFactory
Reset the underlying shared Connection, to be reinitialized on next access.
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 to long.
run() - Method in class org.springframework.util.exec.StreamPumper
Copies data from the input stream to the output stream.
runningAllowed() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListeningContainer
Check whether this container's listeners are generally allowed to run.

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
 
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
 
setAcksUncommitted(long) - Method in class org.springframework.amqp.rabbit.admin.QueueInfo
 
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.AbstractRabbitListeningContainer
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.AbstractRabbitListeningContainer
 
setBlockingQueueConsumerCapacity(int) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
 
setChannelCacheSize(int) - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
 
setChannelTransacted(boolean) - Method in class org.springframework.amqp.rabbit.support.RabbitAccessor
Set the transaction mode that is used for a RabbitMQ Channel, Default is "false".
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
 
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
 
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
 
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.AbstractRabbitListeningContainer
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
 
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
 
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.
setTaskExecutor(Executor) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
 
setTimestamp(Date) - Method in class org.springframework.amqp.core.MessageProperties
 
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
 
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.AbstractRabbitListeningContainer
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.
shouldGenerateId() - Method in class org.springframework.amqp.rabbit.config.RabbitAdminParser
 
shouldGenerateIdAsFallback() - Method in class org.springframework.amqp.rabbit.config.RabbitAdminParser
 
shutdown() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListeningContainer
Stop the shared Connection, call AbstractRabbitListeningContainer.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
 
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
 
SpringRabbitJUnit4ClassRunner - Class in org.springframework.amqp.rabbit.test
A specialized JUnit4 class runner so that we can add a RabbitTestExecutionListener.
SpringRabbitJUnit4ClassRunner(Class<?>) - Constructor for class org.springframework.amqp.rabbit.test.SpringRabbitJUnit4ClassRunner
 
start() - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
 
start() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListeningContainer
Start this container.
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.AbstractRabbitListeningContainer
Stop this container.
stop(Runnable) - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListeningContainer
 
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.AbstractRabbitListeningContainer
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(String) - Method in interface org.springframework.amqp.support.converter.ClassMapper
 
toClass(String) - 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
 
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.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.AbstractRabbitListeningContainer
Validate the configuration of this container.
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.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
 

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 © 2010. All Rights Reserved.