All Classes and Interfaces
Class
Description
Base class for annotated argument binders.
Abstract
ExecutableMethodProcessor for annotations related to
JMSListener.Base class for object pool implementations.
Success handler to acknowledge that the listener has received and processed the message successfully.
Generates the ActiveMQ Artemis
JMSConnectionFactory based on the
properties provided by ActiveMqArtemisConfigurationProperties.Configuration properties for creating the ActiveMQ Artemis
JMSConnectionFactory.Generates the ActiveMQ Classic
JMSConnectionFactory based on the
properties provided by ActiveMqClassicConfigurationProperties.Configuration properties for creating the ActiveMQ Classic
JMSConnectionFactory.Assertion utility methods.
Binds a
Message to a method argument annotated with MessageBody.Binds headers from a
Message to a method argument annotated with
MessageHeader.Binds a
Message to a method argument annotated with Message.Default implementation of
Serializer and Deserializer.Extracts a
Message body to an instance of the specified type.Global handler that handles any errors thrown when handling a message on a
JMSListener.Global handler that handles an action after a message has been received and processed by a
JMSListener.JMS header names must be valid Java identifiers.
An
ArgumentBinderRegistry for all implementations of
ArgumentBinder capable of binding a Message.Generic configuration properties for global Micronaut JMS properties.
Denotes a JMS Connection Factory bean.
Decorator of the provided
ConnectionFactory to ensure maximum reuse
of Connection instances.Helper class that receives messages, configuring JMS connections, sessions,
etc.
The different persistence modes of JMS Brokers.
Enumeration of the types of JMS Destinations.
Utility class for access to the supported JMS Headers, and methods to
extract those values from a given
Message.Reports whether a connection can be opened with each JMS connection factory, and the JMS provider of each.
Declares a class for post-processing.
Sets up and manages
MessageListeners created by the JMSListener and
AbstractJMSListenerMethodProcessor processing.Handles any errors thrown when handling a message on a
JMSListener.The configuration of how listeners recover when the JMS provider reports that the session of a consumer failed.
Registry for all
JMSListeners managed by Micronaut JMS.Handles an action after a message has been received and processed by a
JMSListener.Observes the messages that JMS listeners process and that JMS producers send, for example to record metrics or
traces.
Records the messages that JMS listeners process and that JMS producers send.
The observation of a message that a
JMSMessageObserver started.The observers of the messages of a listener or a producer.
Helper class that sends messages, configuring JMS connections, sessions,
etc.
Declares a class for post-processing.
Sends messages to a broker.
The configuration of the sessions that producer methods send with.
Registers a
JMSListener for
methods annotated with Queue.Registers a
JMSListener for
methods annotated with Topic.A named subscription to a topic: durable, shared, or both.
Traces the messages that JMS listeners process and that JMS producers send with the OpenTelemetry bean of Micronaut
Tracing.
Default logger for all
JMSListeners.An annotation that can be applied to method argument to indicate that the
argument is bound from the JMS
Message.Binds the
MessageBody annotation.An annotation that can be applied to a producer method argument to indicate that the
argument is the delivery mode, a
JMSDeliveryMode or a DeliveryMode value, passed to MessageProducer.send(Message, int, int, long).Handles and converts
Messages.Decorator for converting between
MessageListener and
MessageHandler.Represents a header on a JMS message.
Binds the
MessageHeader annotation.An annotation that can be applied to a producer method argument to indicate that the
argument is the priority, from 0 (lowest) to 9, passed to
MessageProducer.send(Message, int, int, long).Pool for ensuring maximum reuse of
MessageProducers.Factory for generating
MessageProducerPool from a Session.An annotation that can be applied to method argument to indicate that the
argument is bound from the JMS TTL attribute on
MessageProducer.send(Message, int, int, long).The underlying type of a
Message mapped to the corresponding class.Wrapper for
Connection that returns it to the
JMSConnectionPool with a call to AutoCloseable.close().Base class for wrappers of pooled objects.
Pooled object for ensuring maximum reuse of
MessageProducer objects.Wrapper for
Session that returns it to the pool with a call to
AutoCloseable.close().Reuses the sessions of producers across sends, instead of opening a connection and a session for each message.
Binds a
Queue to a method for receiving or sending a Message.Serializes an object into a
Message.A
MessageListener that also receives the Session that consumed the message, so that it can reply,
commit or roll back on that session.Pool for ensuring maximum reuse of
Sessions within an application.Factory for generating a
SessionPool from a Connection.Generates the AWS SQS
JMSConnectionFactory based on the properties
provided by SqsConfigurationProperties.Configuration properties for creating the AWS SQS
JMSConnectionFactory.Annotation to bind a
Topic to a method for receiving or
sending a Message.Attempts to rollback a transaction on the given
Session.Commits a JMS transaction upon successful handling of a message.