|
Spring AMQP | ||||||||
| PREV NEXT | FRAMES NO FRAMES | ||||||||
Declarable classes.MessageConverter implementations.PublisherCallbackChannel.Listener and returns a reference to
the pending confirms map for that listener's pending
confirms, allowing the Listener to
assess unconfirmed sends at any point in time.
autoStartup is set to true, registers a callback on the
ConnectionFactory to declare all exchanges and queues in the enclosing application context.
AbstractMessageListenerContainer.validateConfiguration() and AbstractMessageListenerContainer.initialize().
MethodInterceptor for accessing RMI-style AMQP services.ConnectException which can be commonly thrown from AMQP operations if the
remote process dies or there is a network issue.IOException which
can be commonly thrown from AMQP operations.FactoryBean for AMQP proxies.ConnectionFactory implementation that returns the same Connections from all CachingConnectionFactory.createConnection()
calls, and ignores calls to Connection.close() and caches
Channel.Channel to be implemented by
Channel proxies.AMQP.REPLY_SUCCESS close code
and message 'OK'.
Connections.OtpConnections.ConnectionFactory,
in particular for obtaining transactional Rabbit resources for a given ConnectionFactory.Connection to be implemented by
Connection proxies.Connection to be implemented by Connection proxies.Message and send it to a default exchange with a default routing key.
Message and send it to a default exchange with a specific routing key.
Message and send it to a specific exchange with a specific routing key.
Message and send it to a default exchange with a default routing key.
Message and send it to a default exchange with a specific routing key.
Message and send it to a specific exchange with a specific routing key.
Message.
AmqpAdmin.MessageProperties;
the default name of the message property containing the type is '__TypeId__'.ConnectionProxy that delegates to an underlying OtpConnection.MessagePropertiesConverter strategy.AbstractMessageListenerContainer.shutdown() when the BeanFactory destroys the container instance.
Channel, possibly returning a result.
PumpStreamHandler for stream handling.
Execute to handle input and output stream of
subprocesses.Message into an object.
Connections.
AmqpAdmins that should declare this
object; if empty, all admins should declare.
RabbitAdmin.QUEUE_NAME, RabbitAdmin.QUEUE_MESSAGE_COUNT,
RabbitAdmin.QUEUE_CONSUMER_COUNT, or null if the queue doesn't exist.
recoveryInterval to give the container a
chance to recover from consumer startup failure, e.g.
Channel to a registered ChannelAwareMessageListener.
MessageConverter that uses a Marshaller and Unmarshaller.MarshallingMessageConverter with no Marshaller or Unmarshaller set.
MarshallingMessageConverter with the given Marshaller set.
MarshallingMessageConverter with the
given Marshaller and Unmarshaller.
MessageListenerAdapter with default settings.
MessageListenerAdapter for the given delegate.
MessageListenerAdapter for the given delegate.
MessageListenerAdapter for the given delegate while also
declaring its POJO method.
MessageProperties
and RabbitMQ BasicProperties.MessageListener entry point.
ChannelAwareMessageListener entry point.
IOException which
can be commonly thrown from OTP operations.AmqpException class
hierarchy.PlatformTransactionManager implementation for a single Rabbit
ConnectionFactory.MessageConverter that can work with Strings or native objects of any kind via the
Serializer and Deserializer abstractions in Spring.AmqpAdmins that should declare this object; default is
all admins.
Advice to apply to listener executions.
Connections.
DefaultClassMapper.toClass(MessageProperties) if no type information
is found in the message properties.
ChannelAwareMessageListener as well as
to RabbitTemplate calls.
ObjectMapper to use instead of using the default.
ObjectMapper to use instead of using the default.
Marshaller to be used by this message converter.
StatefulRetryOperationsInterceptorFactoryBean.setMessageKeyGenerator(MessageKeyGenerator) instead
MessagePropertiesConverter for this template.
MessagePropertiesConverter for this listener container.
AmqpAdmin.
Unmarshaller to be used by this message converter.
AmqpAdmin.
AbstractMessageListenerContainer.doShutdown(), and close this container.
ConnectionFactory that return a new connection for each invocation of the
createConnection method.MessageConverter that can work with Strings, Serializable instances,
or byte arrays.ConnectionFactory implementation that returns the same Connections from all
SingleConnectionFactory.createConnection() calls, and ignores calls to Connection.close().
|
Spring AMQP | ||||||||
| PREV NEXT | FRAMES NO FRAMES | ||||||||