Index

A B C D E F G H I J L M N O P Q R S T U V 
All Classes and Interfaces|All Packages|Constant Field Values

A

AbstractJmsArgumentBinder<A> - Class in io.micronaut.jms.bind
Base class for annotated argument binders.
AbstractJmsArgumentBinder(ConversionService) - Constructor for class io.micronaut.jms.bind.AbstractJmsArgumentBinder
Constructor.
AbstractJMSListenerMethodProcessor<T> - Class in io.micronaut.jms.configuration
Abstract ExecutableMethodProcessor for annotations related to JMSListener.
AbstractJMSListenerMethodProcessor(BeanContext, JMSArgumentBinderRegistry, Class) - Constructor for class io.micronaut.jms.configuration.AbstractJMSListenerMethodProcessor
 
AbstractPool<T> - Class in io.micronaut.jms.pool
Base class for object pool implementations.
AbstractPool(int, int) - Constructor for class io.micronaut.jms.pool.AbstractPool
 
acknowledgeMode() - Element in annotation interface io.micronaut.jms.annotations.Queue
 
acknowledgeMode() - Element in annotation interface io.micronaut.jms.annotations.Topic
 
AcknowledgingJMSListenerSuccessHandler - Class in io.micronaut.jms.listener
Success handler to acknowledge that the listener has received and processed the message successfully.
AcknowledgingJMSListenerSuccessHandler() - Constructor for class io.micronaut.jms.listener.AcknowledgingJMSListenerSuccessHandler
 
ActiveMqArtemisConfiguration - Class in io.micronaut.jms.activemq.artemis.configuration
Generates the ActiveMQ Artemis JMSConnectionFactory based on the properties provided by ActiveMqArtemisConfigurationProperties.
ActiveMqArtemisConfiguration() - Constructor for class io.micronaut.jms.activemq.artemis.configuration.ActiveMqArtemisConfiguration
 
ActiveMqArtemisConfigurationProperties - Interface in io.micronaut.jms.activemq.artemis.configuration.properties
Configuration properties for creating the ActiveMQ Artemis JMSConnectionFactory.
activeMqArtemisConnectionFactory(ActiveMqArtemisConfigurationProperties) - Method in class io.micronaut.jms.activemq.artemis.configuration.ActiveMqArtemisConfiguration
Generates a JMSConnectionFactory bean in the application context.
ActiveMqClassicConfiguration - Class in io.micronaut.jms.activemq.classic.configuration
Generates the ActiveMQ Classic JMSConnectionFactory based on the properties provided by ActiveMqClassicConfigurationProperties.
ActiveMqClassicConfiguration() - Constructor for class io.micronaut.jms.activemq.classic.configuration.ActiveMqClassicConfiguration
 
ActiveMqClassicConfigurationProperties - Interface in io.micronaut.jms.activemq.classic.configuration.properties
Configuration properties for creating the ActiveMQ Classic JMSConnectionFactory.
activeMqConnectionFactory(ActiveMqClassicConfigurationProperties) - Method in class io.micronaut.jms.activemq.classic.configuration.ActiveMqClassicConfiguration
Generates a JMSConnectionFactory bean in the application context.
add(Collection) - Method in class io.micronaut.jms.observation.JMSObservations
 
addErrorHandlers(JMSListenerErrorHandler...) - Method in class io.micronaut.jms.listener.JMSListener
 
addErrorHandlers(Collection) - Method in class io.micronaut.jms.listener.JMSListener
 
addObservers(Collection) - Method in class io.micronaut.jms.listener.JMSListener
 
addObservers(Collection) - Method in class io.micronaut.jms.templates.JmsProducer
 
addSuccessHandlers(JMSListenerSuccessHandler...) - Method in class io.micronaut.jms.listener.JMSListener
 
addSuccessHandlers(Collection) - Method in class io.micronaut.jms.listener.JMSListener
 
apply(Message) - Method in class io.micronaut.jms.model.MessageHeader
If this is a supported JMS header, attempts to set the header given by the key with the value given with value, doing all required type conversions.
Assert - Class in io.micronaut.jms.util
Assertion utility methods.
Assert() - Constructor for class io.micronaut.jms.util.Assert
 

B

beanContext - Variable in class io.micronaut.jms.configuration.AbstractJMSListenerMethodProcessor
 
beforeSend(Message) - Method in interface io.micronaut.jms.observation.JMSObservation
Called on the observation of a send once the message is created and its headers are set, just before it is sent, so properties added to the message, such as a trace context, are sent with it.
beforeSend(List, Message) - Static method in class io.micronaut.jms.observation.JMSObservations
Passes the message that is about to be sent to observations, in the order of their start.
bind(ArgumentConversionContext, Message) - Method in class io.micronaut.jms.bind.DefaultBodyArgumentBinder
 
bind(ArgumentConversionContext, Message) - Method in class io.micronaut.jms.bind.DefaultHeaderArgumentBinder
 
bind(ArgumentConversionContext, Message) - Method in class io.micronaut.jms.bind.DefaultMessageArgumentBinder
 
bind(ArgumentConversionContext, Message) - Method in class io.micronaut.jms.bind.MessageBodyHeaderArgumentBinder
 
bind(ArgumentConversionContext, Message) - Method in class io.micronaut.jms.bind.MessageHeaderArgumentBinder
 
borrow(boolean, int) - Method in class io.micronaut.jms.pool.ProducerSessionPool
Borrows a session, which must be returned with ProducerSessionPool.release(Session, boolean).
BYTES - Enum constant in enum class io.micronaut.jms.model.MessageType
A BytesMessage to be deserialized to a byte array.

C

checkSession(Session) - Method in interface io.micronaut.jms.listener.SessionAwareMessageListener
Checks that this listener can handle the messages of a session, before JMSListener consumes any of them.
clientId() - Element in annotation interface io.micronaut.jms.annotations.Topic
The client ID of the listener's connection.
clientId() - Method in record class io.micronaut.jms.listener.JMSTopicSubscription
Returns the value of the clientId record component.
close() - Method in class io.micronaut.jms.pool.PooledObject
 
close() - Method in class io.micronaut.jms.pool.ProducerSessionPool
Closes the idle sessions and the connections, which also closes the sessions that are still borrowed.
commit() - Method in class io.micronaut.jms.pool.PooledSession
 
complete(Throwable) - Method in interface io.micronaut.jms.observation.JMSObservation
Completes the observation, on the thread that started it.
complete(List, Throwable) - Static method in class io.micronaut.jms.observation.JMSObservations
Completes observations in the reverse order of their start.
CONNECTION_FACTORY_BEAN_NAME - Static variable in class io.micronaut.jms.activemq.artemis.configuration.ActiveMqArtemisConfiguration
Name of the ActiveMQ Artemis ConnectionFactory bean.
CONNECTION_FACTORY_BEAN_NAME - Static variable in class io.micronaut.jms.activemq.classic.configuration.ActiveMqClassicConfiguration
Name of the ActiveMQ Classic ConnectionFactory bean.
CONNECTION_FACTORY_BEAN_NAME - Static variable in class io.micronaut.jms.sqs.configuration.SqsConfiguration
Name of the SQS ConnectionFactory bean.
consumers() - Element in annotation interface io.micronaut.jms.annotations.Queue
The number of consumers of the listener method, each with its own session, so that messages are handled concurrently.
consumers() - Element in annotation interface io.micronaut.jms.annotations.Topic
The number of consumers of the listener method, each with its own session, so that messages are handled concurrently.
create(Object...) - Method in class io.micronaut.jms.pool.AbstractPool
Create an object for the pool.
create(Object...) - Method in class io.micronaut.jms.pool.JMSConnectionPool
 
create(Object...) - Method in class io.micronaut.jms.pool.MessageProducerPool
 
create(Object...) - Method in class io.micronaut.jms.pool.SessionPool
 
createBrowser(Queue) - Method in class io.micronaut.jms.pool.PooledSession
 
createBrowser(Queue, String) - Method in class io.micronaut.jms.pool.PooledSession
 
createBytesMessage() - Method in class io.micronaut.jms.pool.PooledSession
 
createConnection() - Method in class io.micronaut.jms.pool.JMSConnectionPool
 
createConnection(String, String) - Method in class io.micronaut.jms.pool.JMSConnectionPool
 
createConnectionConsumer(Destination, String, ServerSessionPool, int) - Method in class io.micronaut.jms.pool.PooledConnection
 
createConsumer(Destination) - Method in class io.micronaut.jms.pool.PooledSession
 
createConsumer(Destination, String) - Method in class io.micronaut.jms.pool.PooledSession
 
createConsumer(Destination, String, boolean) - Method in class io.micronaut.jms.pool.PooledSession
 
createContext() - Method in class io.micronaut.jms.pool.JMSConnectionPool
 
createContext(int) - Method in class io.micronaut.jms.pool.JMSConnectionPool
 
createContext(String, String) - Method in class io.micronaut.jms.pool.JMSConnectionPool
 
createContext(String, String, int) - Method in class io.micronaut.jms.pool.JMSConnectionPool
 
createDurableConnectionConsumer(Topic, String, String, ServerSessionPool, int) - Method in class io.micronaut.jms.pool.PooledConnection
 
createDurableConsumer(Topic, String) - Method in class io.micronaut.jms.pool.PooledSession
 
createDurableConsumer(Topic, String, String, boolean) - Method in class io.micronaut.jms.pool.PooledSession
 
createDurableSubscriber(Topic, String) - Method in class io.micronaut.jms.pool.PooledSession
 
createDurableSubscriber(Topic, String, String, boolean) - Method in class io.micronaut.jms.pool.PooledSession
 
createMapMessage() - Method in class io.micronaut.jms.pool.PooledSession
 
createMessage() - Method in class io.micronaut.jms.pool.PooledSession
 
createObjectMessage() - Method in class io.micronaut.jms.pool.PooledSession
 
createObjectMessage(Serializable) - Method in class io.micronaut.jms.pool.PooledSession
 
createProducer(Destination) - Method in class io.micronaut.jms.pool.PooledSession
 
createQueue(String) - Method in class io.micronaut.jms.pool.PooledSession
 
createSession() - Method in class io.micronaut.jms.pool.PooledConnection
 
createSession(boolean, int) - Method in class io.micronaut.jms.pool.PooledConnection
 
createSession(int) - Method in class io.micronaut.jms.pool.PooledConnection
 
createSharedConnectionConsumer(Topic, String, String, ServerSessionPool, int) - Method in class io.micronaut.jms.pool.PooledConnection
 
createSharedConsumer(Topic, String) - Method in class io.micronaut.jms.pool.PooledSession
 
createSharedConsumer(Topic, String, String) - Method in class io.micronaut.jms.pool.PooledSession
 
createSharedDurableConnectionConsumer(Topic, String, String, ServerSessionPool, int) - Method in class io.micronaut.jms.pool.PooledConnection
 
createSharedDurableConsumer(Topic, String) - Method in class io.micronaut.jms.pool.PooledSession
 
createSharedDurableConsumer(Topic, String, String) - Method in class io.micronaut.jms.pool.PooledSession
 
createStreamMessage() - Method in class io.micronaut.jms.pool.PooledSession
 
createTemporaryQueue() - Method in class io.micronaut.jms.pool.PooledSession
 
createTemporaryTopic() - Method in class io.micronaut.jms.pool.PooledSession
 
createTextMessage() - Method in class io.micronaut.jms.pool.PooledSession
 
createTextMessage(String) - Method in class io.micronaut.jms.pool.PooledSession
 
createTopic(String) - Method in class io.micronaut.jms.pool.PooledSession
 

D

DASH - Static variable in class io.micronaut.jms.tracing.opentelemetry.JMSTracing
The replacement of dashes in the names of message properties.
decode(String) - Static method in class io.micronaut.jms.util.HeaderNameUtils
 
DEFAULT_ENABLED - Static variable in interface io.micronaut.jms.configuration.properties.JMSListenerRecoveryConfiguration
Whether recovery is enabled by default.
DEFAULT_INITIAL_DELAY - Static variable in interface io.micronaut.jms.configuration.properties.JMSListenerRecoveryConfiguration
The default delay after the first failed attempt.
DEFAULT_MAX_ACTIVE - Static variable in class io.micronaut.jms.pool.ProducerSessionPool
The default maximum number of sessions that are borrowed at once.
DEFAULT_MAX_DELAY - Static variable in interface io.micronaut.jms.configuration.properties.JMSListenerRecoveryConfiguration
The default longest delay between two attempts.
DEFAULT_MAX_WAIT - Static variable in class io.micronaut.jms.pool.ProducerSessionPool
The default time that a send waits for a session when the maximum number of sessions are borrowed.
DEFAULT_POSITION - Static variable in interface io.micronaut.jms.listener.JMSListenerSuccessHandler
 
DEFAULT_WARN_ATTEMPTS - Static variable in interface io.micronaut.jms.configuration.properties.JMSListenerRecoveryConfiguration
The default number of failed attempts logged as warnings.
DefaultBodyArgumentBinder - Class in io.micronaut.jms.bind
Binds a Message to a method argument annotated with MessageBody.
DefaultBodyArgumentBinder(ConversionService, Deserializer) - Constructor for class io.micronaut.jms.bind.DefaultBodyArgumentBinder
Constructor.
DefaultHeaderArgumentBinder - Class in io.micronaut.jms.bind
Binds headers from a Message to a method argument annotated with MessageHeader.
DefaultHeaderArgumentBinder(ConversionService) - Constructor for class io.micronaut.jms.bind.DefaultHeaderArgumentBinder
Constructor.
DefaultMessageArgumentBinder - Class in io.micronaut.jms.bind
Binds a Message to a method argument annotated with Message.
DefaultMessageArgumentBinder(ConversionService) - Constructor for class io.micronaut.jms.bind.DefaultMessageArgumentBinder
Constructor.
DefaultSerializerDeserializer - Class in io.micronaut.jms.serdes
Default implementation of Serializer and Deserializer.
DefaultSerializerDeserializer(BeanLocator) - Constructor for class io.micronaut.jms.serdes.DefaultSerializerDeserializer
 
deliveryMode() - Element in annotation interface io.micronaut.jms.annotations.Queue
The delivery mode of the messages that a producer method sends.
deliveryMode() - Element in annotation interface io.micronaut.jms.annotations.Topic
The delivery mode of the messages that a producer method sends.
deserialize(Message) - Method in interface io.micronaut.jms.serdes.Deserializer
Extract the body of the message into a sensible type.
deserialize(Message, Argument) - Method in class io.micronaut.jms.serdes.DefaultSerializerDeserializer
 
deserialize(Message, Argument) - Method in interface io.micronaut.jms.serdes.Deserializer
Extract the body of the message into the specified type.
deserialize(Message, Class) - Method in class io.micronaut.jms.serdes.DefaultSerializerDeserializer
 
deserialize(Message, Class) - Method in interface io.micronaut.jms.serdes.Deserializer
Extract the body of the message into the specified type.
deserializer() - Element in annotation interface io.micronaut.jms.annotations.Queue
The name of a Deserializer in the bean context that a listener method uses to convert each Message of the queue into its @MessageBody argument.
deserializer() - Element in annotation interface io.micronaut.jms.annotations.Topic
The name of a Deserializer in the bean context that a listener method uses to convert each Message of the topic into its @MessageBody argument.
Deserializer - Interface in io.micronaut.jms.serdes
Extracts a Message body to an instance of the specified type.
discard(PooledObject) - Method in class io.micronaut.jms.pool.JMSConnectionPool
 
discard(T) - Method in class io.micronaut.jms.pool.AbstractPool
Releases the resources of an invalid object, which leaves the pool.
durable() - Element in annotation interface io.micronaut.jms.annotations.Topic
Whether the subscription is durable, so messages published while the listener is not connected are kept for it.
durable() - Method in record class io.micronaut.jms.listener.JMSTopicSubscription
Returns the value of the durable record component.

E

effectiveClientId() - Method in record class io.micronaut.jms.listener.JMSTopicSubscription
 
ENABLED - Static variable in class io.micronaut.jms.health.JMSHealthIndicator
The property that disables the indicator.
ENABLED - Static variable in class io.micronaut.jms.metrics.JMSMetrics
The property that disables the metrics.
ENABLED - Static variable in class io.micronaut.jms.tracing.opentelemetry.JMSTracing
The property that disables tracing.
encode(String) - Static method in class io.micronaut.jms.util.HeaderNameUtils
 
equals(Object) - Method in record class io.micronaut.jms.listener.JMSTopicSubscription
Indicates whether some other object is "equal to" this one.
errorHandlers() - Element in annotation interface io.micronaut.jms.annotations.JMSListener
The error handlers to be injected into the message handling logic for all Queue or Topic methods.
errorHandlers() - Element in annotation interface io.micronaut.jms.annotations.Queue
The error handlers to be injected into the message handling logic.
errorHandlers() - Element in annotation interface io.micronaut.jms.annotations.Topic
The error handlers to be injected into the message handling logic.

F

findArgumentBinder(Argument) - Method in class io.micronaut.jms.bind.JMSArgumentBinderRegistry
 
from(int) - Static method in enum class io.micronaut.jms.model.JMSDeliveryMode
 
fromMessage(Message) - Static method in enum class io.micronaut.jms.model.MessageType
Determine the MessageType corresponding to the given message.
fromObject(Object) - Static method in enum class io.micronaut.jms.model.MessageType
Determine the MessageType corresponding to the given message.

G

get() - Method in class io.micronaut.jms.pool.PooledObject
Retrieve the underlying pooled object.
getAcknowledgeMode() - Method in class io.micronaut.jms.pool.PooledSession
 
getAnnotationType() - Method in class io.micronaut.jms.bind.DefaultBodyArgumentBinder
 
getAnnotationType() - Method in class io.micronaut.jms.bind.DefaultHeaderArgumentBinder
 
getAnnotationType() - Method in class io.micronaut.jms.bind.DefaultMessageArgumentBinder
 
getAnnotationType() - Method in class io.micronaut.jms.bind.MessageBodyHeaderArgumentBinder
 
getAnnotationType() - Method in class io.micronaut.jms.bind.MessageHeaderArgumentBinder
 
getBorrowedCount() - Method in class io.micronaut.jms.pool.ProducerSessionPool
 
getClientID() - Method in class io.micronaut.jms.pool.PooledConnection
 
getConnectionFactory() - Method in class io.micronaut.jms.pool.JMSConnectionPool
Provides access to the underlying ConnectionFactory.
getConnectionString() - Method in interface io.micronaut.jms.activemq.artemis.configuration.properties.ActiveMqArtemisConfigurationProperties
The connection string to identify the broker URL, e.g.
getConnectionString() - Method in interface io.micronaut.jms.activemq.classic.configuration.properties.ActiveMqClassicConfigurationProperties
The connection string to identify the broker URL, e.g.
getDeliveryDelay() - Method in class io.micronaut.jms.pool.PooledProducer
 
getDeliveryMode() - Method in class io.micronaut.jms.pool.PooledProducer
 
getDestination() - Method in class io.micronaut.jms.pool.PooledProducer
 
getDestinationType() - Method in class io.micronaut.jms.configuration.AbstractJMSListenerMethodProcessor
 
getDestinationType() - Method in class io.micronaut.jms.configuration.JMSQueueListenerMethodProcessor
 
getDestinationType() - Method in class io.micronaut.jms.configuration.JMSTopicListenerMethodProcessor
 
getDisableMessageID() - Method in class io.micronaut.jms.pool.PooledProducer
 
getDisableMessageTimestamp() - Method in class io.micronaut.jms.pool.PooledProducer
 
getExceptionListener() - Method in class io.micronaut.jms.pool.PooledConnection
 
getExecutorService(AnnotationValue) - Method in class io.micronaut.jms.configuration.JMSQueueListenerMethodProcessor
 
getExecutorService(AnnotationValue) - Method in class io.micronaut.jms.configuration.JMSTopicListenerMethodProcessor
 
getExecutorService(AnnotationValue) - Method in class io.micronaut.jms.configuration.AbstractJMSListenerMethodProcessor
 
getHeader(String, Message, Class) - Static method in class io.micronaut.jms.model.JMSHeaders
Attempts to retrieve the value of the header given by headerName from the given message.
getIdleCount() - Method in class io.micronaut.jms.pool.ProducerSessionPool
 
getInitialDelay() - Method in interface io.micronaut.jms.configuration.properties.JMSListenerRecoveryConfiguration
 
getInitialPoolSize() - Method in interface io.micronaut.jms.configuration.properties.JMSConfigurationProperties
The initial size of the JMSConnectionPool, SessionPool, and MessageProducerPool.
getMaxActive() - Method in interface io.micronaut.jms.configuration.properties.JMSProducerSessionConfiguration
 
getMaxDelay() - Method in interface io.micronaut.jms.configuration.properties.JMSListenerRecoveryConfiguration
 
getMaxIdle() - Method in interface io.micronaut.jms.configuration.properties.JMSProducerSessionConfiguration
 
getMaxPoolSize() - Method in interface io.micronaut.jms.configuration.properties.JMSConfigurationProperties
The maximum size of the JMSConnectionPool, SessionPool, and MessageProducerPool.
getMaxWait() - Method in interface io.micronaut.jms.configuration.properties.JMSProducerSessionConfiguration
 
getMessageListener() - Method in class io.micronaut.jms.pool.PooledSession
 
getMetaData() - Method in class io.micronaut.jms.pool.PooledConnection
 
getNumberOfMessagesToPrefetch() - Method in interface io.micronaut.jms.sqs.configuration.properties.SqsConfigurationProperties
Number of messages to prefetch for better receive turnaround times.
getOrder() - Method in class io.micronaut.jms.bind.AbstractJmsArgumentBinder
 
getOrder() - Method in interface io.micronaut.jms.listener.JMSListenerSuccessHandler
 
getOrder() - Method in class io.micronaut.jms.listener.TransactionalJMSListenerErrorHandler
 
getOrder() - Method in class io.micronaut.jms.listener.TransactionalJMSListenerSuccessHandler
 
getOrder() - Method in class io.micronaut.jms.metrics.JMSMetrics
 
getPassword() - Method in interface io.micronaut.jms.activemq.artemis.configuration.properties.ActiveMqArtemisConfigurationProperties
The password.
getPassword() - Method in interface io.micronaut.jms.activemq.classic.configuration.properties.ActiveMqClassicConfigurationProperties
The password.
getPriority() - Method in class io.micronaut.jms.pool.PooledProducer
 
getProducerPool(Session) - Method in class io.micronaut.jms.pool.MessageProducerPoolFactory
Generates and configures a MessageProducerPool given a Session.
getResult() - Method in class io.micronaut.jms.health.JMSHealthIndicator
 
getSessionPool(Connection) - Method in class io.micronaut.jms.pool.SessionPoolFactory
Returns a SessionPool from the provided connection.
getTimeToLive() - Method in class io.micronaut.jms.pool.PooledProducer
 
getTransacted() - Method in class io.micronaut.jms.pool.PooledSession
 
getUsername() - Method in interface io.micronaut.jms.activemq.artemis.configuration.properties.ActiveMqArtemisConfigurationProperties
The username.
getUsername() - Method in interface io.micronaut.jms.activemq.classic.configuration.properties.ActiveMqClassicConfigurationProperties
The username.
getValue() - Method in enum class io.micronaut.jms.model.JMSDeliveryMode
 
getWarnAttempts() - Method in interface io.micronaut.jms.configuration.properties.JMSListenerRecoveryConfiguration
 
GlobalJMSListenerErrorHandler - Interface in io.micronaut.jms.listener
Global handler that handles any errors thrown when handling a message on a JMSListener.
GlobalJMSListenerSuccessHandler - Interface in io.micronaut.jms.listener
Global handler that handles an action after a message has been received and processed by a JMSListener.

H

handle(Session, Message) - Method in interface io.micronaut.jms.listener.JMSListenerSuccessHandler
Handle the successfully processed message.
handle(Session, Message, Throwable) - Method in interface io.micronaut.jms.listener.JMSListenerErrorHandler
Handles the exception thrown during message processing.
handle(Session, Message) - Method in class io.micronaut.jms.listener.AcknowledgingJMSListenerSuccessHandler
 
handle(Session, Message) - Method in class io.micronaut.jms.listener.TransactionalJMSListenerSuccessHandler
 
handle(Session, Message, Throwable) - Method in class io.micronaut.jms.listener.LoggingJMSListenerErrorHandler
 
handle(Session, Message, Throwable) - Method in class io.micronaut.jms.listener.TransactionalJMSListenerErrorHandler
 
handle(T) - Method in interface io.micronaut.jms.listener.MessageHandler
Perform some action when receiving a message.
hashCode() - Method in record class io.micronaut.jms.listener.JMSTopicSubscription
Returns a hash code value for this object.
HeaderNameUtils - Class in io.micronaut.jms.util
JMS header names must be valid Java identifiers.
HeaderNameUtils() - Constructor for class io.micronaut.jms.util.HeaderNameUtils
 

I

initialSize - Variable in class io.micronaut.jms.pool.AbstractPool
 
INSTRUMENTATION_SCOPE - Static variable in class io.micronaut.jms.tracing.opentelemetry.JMSTracing
The name of the instrumentation scope of the spans.
intercept(MethodInvocationContext) - Method in class io.micronaut.jms.configuration.JMSProducerMethodInterceptor
 
io.micronaut.jms.activemq.artemis.configuration - package io.micronaut.jms.activemq.artemis.configuration
Connection factory configuration for ActiveMQ Artemis.
io.micronaut.jms.activemq.artemis.configuration.properties - package io.micronaut.jms.activemq.artemis.configuration.properties
Configuration properties for ActiveMQ Artemis.
io.micronaut.jms.activemq.classic.configuration - package io.micronaut.jms.activemq.classic.configuration
Connection factory configuration for ActiveMQ Classic.
io.micronaut.jms.activemq.classic.configuration.properties - package io.micronaut.jms.activemq.classic.configuration.properties
Configuration properties for ActiveMQ Classic.
io.micronaut.jms.annotations - package io.micronaut.jms.annotations
Annotations for creating JMS consumers and producers.
io.micronaut.jms.bind - package io.micronaut.jms.bind
Classes related to binding JMS Message instances to method signatures.
io.micronaut.jms.configuration - package io.micronaut.jms.configuration
Configuration classes.
io.micronaut.jms.configuration.properties - package io.micronaut.jms.configuration.properties
Configuration property classes.
io.micronaut.jms.health - package io.micronaut.jms.health
Health indicator of the JMS connection factories.
io.micronaut.jms.info - package io.micronaut.jms.info
 
io.micronaut.jms.listener - package io.micronaut.jms.listener
JMS message listener classes.
io.micronaut.jms.metrics - package io.micronaut.jms.metrics
Metrics of the JMS listeners and producers.
io.micronaut.jms.model - package io.micronaut.jms.model
Enum classes.
io.micronaut.jms.observation - package io.micronaut.jms.observation
Observation of the messages that JMS listeners process and that JMS producers send.
io.micronaut.jms.pool - package io.micronaut.jms.pool
Object pool classes for JMS connections, message producers, and sessions.
io.micronaut.jms.serdes - package io.micronaut.jms.serdes
Message serialization/deserialization classes.
io.micronaut.jms.sqs.configuration - package io.micronaut.jms.sqs.configuration
Connection factory configuration for SQS.
io.micronaut.jms.sqs.configuration.properties - package io.micronaut.jms.sqs.configuration.properties
Configuration properties for SQS.
io.micronaut.jms.templates - package io.micronaut.jms.templates
Utility template classes to send and receive messages.
io.micronaut.jms.tracing.opentelemetry - package io.micronaut.jms.tracing.opentelemetry
OpenTelemetry tracing of the JMS listeners and producers.
io.micronaut.jms.util - package io.micronaut.jms.util
Utility classes.
isBroken() - Method in class io.micronaut.jms.pool.PooledConnection
 
isEmpty() - Method in class io.micronaut.jms.observation.JMSObservations
 
isEnabled() - Method in interface io.micronaut.jms.activemq.artemis.configuration.properties.ActiveMqArtemisConfigurationProperties
Whether ActiveMQ Artemis is active.
isEnabled() - Method in interface io.micronaut.jms.activemq.classic.configuration.properties.ActiveMqClassicConfigurationProperties
Whether ActiveMQ Classic is active.
isEnabled() - Method in interface io.micronaut.jms.configuration.properties.JMSListenerRecoveryConfiguration
 
isEnabled() - Method in interface io.micronaut.jms.configuration.properties.JMSProducerSessionConfiguration
 
isEnabled() - Method in interface io.micronaut.jms.sqs.configuration.properties.SqsConfigurationProperties
Whether SQS is active.
isJMSHeader(String) - Static method in class io.micronaut.jms.model.JMSHeaders
 
isTrue(boolean, Supplier) - Static method in class io.micronaut.jms.util.Assert
Throws an IllegalArgumentException if the boolean expression is false.
isValid(PooledObject) - Method in class io.micronaut.jms.pool.JMSConnectionPool
 
isValid(T) - Method in class io.micronaut.jms.pool.AbstractPool
 

J

JMS_CORRELATION_ID - Static variable in class io.micronaut.jms.model.JMSHeaders
Name of the Correlation ID header.
JMS_DELIVERY_MODE - Static variable in class io.micronaut.jms.model.JMSHeaders
Name of the Delivery Mode header.
JMS_DELIVERY_TIME - Static variable in class io.micronaut.jms.model.JMSHeaders
Name of the Delivery Time header.
JMS_DESTINATION - Static variable in class io.micronaut.jms.model.JMSHeaders
Name of the Destination header.
JMS_EXPIRATION - Static variable in class io.micronaut.jms.model.JMSHeaders
Name of the Expiration header.
JMS_MESSAGE_ID - Static variable in class io.micronaut.jms.model.JMSHeaders
Name of the ID header.
JMS_PRIORITY - Static variable in class io.micronaut.jms.model.JMSHeaders
Name of the Priority header.
JMS_REDELIVERED - Static variable in class io.micronaut.jms.model.JMSHeaders
Name of the Redelivered header.
JMS_REPLY_TO - Static variable in class io.micronaut.jms.model.JMSHeaders
Name of the Reply To header.
JMS_TIMESTAMP - Static variable in class io.micronaut.jms.model.JMSHeaders
Name of the Timestamp header.
JMS_TYPE - Static variable in class io.micronaut.jms.model.JMSHeaders
Name of the Type header.
JMSArgumentBinderRegistry - Class in io.micronaut.jms.bind
An ArgumentBinderRegistry for all implementations of ArgumentBinder capable of binding a Message.
JMSArgumentBinderRegistry(ConversionService, BeanContext) - Constructor for class io.micronaut.jms.bind.JMSArgumentBinderRegistry
 
JMSArgumentBinderRegistry(ConversionService, Deserializer) - Constructor for class io.micronaut.jms.bind.JMSArgumentBinderRegistry
 
JMSConfigurationProperties - Interface in io.micronaut.jms.configuration.properties
Generic configuration properties for global Micronaut JMS properties.
JMSConnectionFactory - Annotation Interface in io.micronaut.jms.annotations
Denotes a JMS Connection Factory bean.
JMSConnectionPool - Class in io.micronaut.jms.pool
Decorator of the provided ConnectionFactory to ensure maximum reuse of Connection instances.
JMSConnectionPool(ConnectionFactory, int, int) - Constructor for class io.micronaut.jms.pool.JMSConnectionPool
 
JmsConsumer - Class in io.micronaut.jms.templates
Helper class that receives messages, configuring JMS connections, sessions, etc.
JmsConsumer(JMSDestinationType, JMSConnectionPool, Deserializer) - Constructor for class io.micronaut.jms.templates.JmsConsumer
 
JmsConsumer(JMSDestinationType, JMSConnectionPool, Deserializer, boolean, int) - Constructor for class io.micronaut.jms.templates.JmsConsumer
 
JMSDeliveryMode - Enum Class in io.micronaut.jms.model
The different persistence modes of JMS Brokers.
JMSDestinationType - Enum Class in io.micronaut.jms.model
Enumeration of the types of JMS Destinations.
JMSHeaders - Class in io.micronaut.jms.model
Utility class for access to the supported JMS Headers, and methods to extract those values from a given Message.
JMSHealthIndicator - Class in io.micronaut.jms.health
Reports whether a connection can be opened with each JMS connection factory, and the JMS provider of each.
JMSListener - Class in io.micronaut.jms.listener
Sets up and manages MessageListeners created by the JMSListener and AbstractJMSListenerMethodProcessor processing.
JMSListener - Annotation Interface in io.micronaut.jms.annotations
Declares a class for post-processing.
JMSListener(Session, MessageListener, JMSDestinationType, String, ExecutorService, Optional) - Constructor for class io.micronaut.jms.listener.JMSListener
Creates a JMSListener instance.
JMSListener(Session, MessageListener, JMSDestinationType, String, ExecutorService, Optional, JMSTopicSubscription) - Constructor for class io.micronaut.jms.listener.JMSListener
Creates a JMSListener instance, optionally with a named topic subscription.
JMSListenerErrorHandler - Interface in io.micronaut.jms.listener
Handles any errors thrown when handling a message on a JMSListener.
JMSListenerRecoveryConfiguration - Interface in io.micronaut.jms.configuration.properties
The configuration of how listeners recover when the JMS provider reports that the session of a consumer failed.
JMSListenerRegistry - Class in io.micronaut.jms.listener
Registry for all JMSListeners managed by Micronaut JMS.
JMSListenerRegistry(Collection, Collection) - Constructor for class io.micronaut.jms.listener.JMSListenerRegistry
Deprecated, for removal: This API element is subject to removal in a future version.
JMSListenerRegistry(Collection, Collection, Collection, JMSListenerRecoveryConfiguration) - Constructor for class io.micronaut.jms.listener.JMSListenerRegistry
 
JMSListenerSuccessHandler - Interface in io.micronaut.jms.listener
Handles an action after a message has been received and processed by a JMSListener.
JMSMessageObserver - Interface in io.micronaut.jms.observation
Observes the messages that JMS listeners process and that JMS producers send, for example to record metrics or traces.
JMSMetrics - Class in io.micronaut.jms.metrics
Records the messages that JMS listeners process and that JMS producers send.
JMSObservation - Interface in io.micronaut.jms.observation
The observation of a message that a JMSMessageObserver started.
JMSObservations - Class in io.micronaut.jms.observation
The observers of the messages of a listener or a producer.
JMSObservations() - Constructor for class io.micronaut.jms.observation.JMSObservations
 
JmsProducer<T> - Class in io.micronaut.jms.templates
Helper class that sends messages, configuring JMS connections, sessions, etc.
JmsProducer(JMSDestinationType, JMSConnectionPool, Serializer) - Constructor for class io.micronaut.jms.templates.JmsProducer
 
JmsProducer(JMSDestinationType, JMSConnectionPool, Serializer, boolean, int) - Constructor for class io.micronaut.jms.templates.JmsProducer
 
JmsProducer(JMSDestinationType, JMSConnectionPool, Serializer, boolean, int, ProducerSessionPool) - Constructor for class io.micronaut.jms.templates.JmsProducer
 
JMSProducer - Annotation Interface in io.micronaut.jms.annotations
Declares a class for post-processing.
JMSProducerMethodInterceptor - Class in io.micronaut.jms.configuration
Sends messages to a broker.
JMSProducerMethodInterceptor(BeanContext) - Constructor for class io.micronaut.jms.configuration.JMSProducerMethodInterceptor
 
JMSProducerSessionConfiguration - Interface in io.micronaut.jms.configuration.properties
The configuration of the sessions that producer methods send with.
JMSQueueListenerMethodProcessor - Class in io.micronaut.jms.configuration
Registers a JMSListener for methods annotated with Queue.
JMSQueueListenerMethodProcessor(BeanContext, JMSArgumentBinderRegistry) - Constructor for class io.micronaut.jms.configuration.JMSQueueListenerMethodProcessor
 
JMSTopicListenerMethodProcessor - Class in io.micronaut.jms.configuration
Registers a JMSListener for methods annotated with Topic.
JMSTopicListenerMethodProcessor(BeanContext, JMSArgumentBinderRegistry) - Constructor for class io.micronaut.jms.configuration.JMSTopicListenerMethodProcessor
 
JMSTopicSubscription - Record Class in io.micronaut.jms.listener
A named subscription to a topic: durable, shared, or both.
JMSTopicSubscription(String, boolean, boolean, String) - Constructor for record class io.micronaut.jms.listener.JMSTopicSubscription
Creates an instance of a JMSTopicSubscription record class.
JMSTracing - Class in io.micronaut.jms.tracing.opentelemetry
Traces the messages that JMS listeners process and that JMS producers send with the OpenTelemetry bean of Micronaut Tracing.

L

LISTENER_DURATION - Static variable in class io.micronaut.jms.metrics.JMSMetrics
The name of the timer of the messages that listeners process.
LISTENER_MESSAGES - Static variable in class io.micronaut.jms.metrics.JMSMetrics
The name of the counter of the messages that listeners process.
logger - Variable in class io.micronaut.jms.configuration.AbstractJMSListenerMethodProcessor
 
LoggingJMSListenerErrorHandler - Class in io.micronaut.jms.listener
Default logger for all JMSListeners.
LoggingJMSListenerErrorHandler() - Constructor for class io.micronaut.jms.listener.LoggingJMSListenerErrorHandler
 

M

MAP - Enum constant in enum class io.micronaut.jms.model.MessageType
A MapMessage to be deserialized to a Map.
maxSize - Variable in class io.micronaut.jms.pool.AbstractPool
 
Message - Annotation Interface in io.micronaut.jms.annotations
An annotation that can be applied to method argument to indicate that the argument is bound from the JMS Message.
MessageBodyHeaderArgumentBinder - Class in io.micronaut.jms.bind
Binds the MessageBody annotation.
MessageBodyHeaderArgumentBinder(ConversionService, Deserializer) - Constructor for class io.micronaut.jms.bind.MessageBodyHeaderArgumentBinder
Constructor.
MessageDeliveryMode - Annotation Interface in io.micronaut.jms.annotations
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).
MessageHandler<T> - Interface in io.micronaut.jms.listener
Handles and converts Messages.
MessageHandlerAdapter<T> - Class in io.micronaut.jms.listener
Decorator for converting between MessageListener and MessageHandler.
MessageHandlerAdapter(MessageHandler, Class) - Constructor for class io.micronaut.jms.listener.MessageHandlerAdapter
 
MessageHandlerAdapter(MessageHandler, Class, Deserializer) - Constructor for class io.micronaut.jms.listener.MessageHandlerAdapter
 
MessageHeader - Class in io.micronaut.jms.model
Represents a header on a JMS message.
MessageHeader(String, Object) - Constructor for class io.micronaut.jms.model.MessageHeader
Creates a container for the message header.
MessageHeaderArgumentBinder - Class in io.micronaut.jms.bind
Binds the MessageHeader annotation.
MessageHeaderArgumentBinder(ConversionService) - Constructor for class io.micronaut.jms.bind.MessageHeaderArgumentBinder
Constructor.
MessagePriority - Annotation Interface in io.micronaut.jms.annotations
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).
MessageProducerPool - Class in io.micronaut.jms.pool
Pool for ensuring maximum reuse of MessageProducers.
MessageProducerPool(int, int, Session) - Constructor for class io.micronaut.jms.pool.MessageProducerPool
 
MessageProducerPoolFactory - Class in io.micronaut.jms.pool
Factory for generating MessageProducerPool from a Session.
MessageProducerPoolFactory() - Constructor for class io.micronaut.jms.pool.MessageProducerPoolFactory
 
messageSelector() - Element in annotation interface io.micronaut.jms.annotations.Queue
 
messageSelector() - Element in annotation interface io.micronaut.jms.annotations.Topic
 
MessageTTL - Annotation Interface in io.micronaut.jms.annotations
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).
MessageType - Enum Class in io.micronaut.jms.model
The underlying type of a Message mapped to the corresponding class.
MicronautJmsActivemqArtemisModuleInfo - Class in io.micronaut.jms.info
 
MicronautJmsActivemqArtemisModuleInfo() - Constructor for class io.micronaut.jms.info.MicronautJmsActivemqArtemisModuleInfo
 
MicronautJmsActivemqClassicModuleInfo - Class in io.micronaut.jms.info
 
MicronautJmsActivemqClassicModuleInfo() - Constructor for class io.micronaut.jms.info.MicronautJmsActivemqClassicModuleInfo
 
MicronautJmsCoreModuleInfo - Class in io.micronaut.jms.info
 
MicronautJmsCoreModuleInfo() - Constructor for class io.micronaut.jms.info.MicronautJmsCoreModuleInfo
 
MicronautJmsSqsModuleInfo - Class in io.micronaut.jms.info
 
MicronautJmsSqsModuleInfo() - Constructor for class io.micronaut.jms.info.MicronautJmsSqsModuleInfo
 
MicronautJmsTracingOpentelemetryModuleInfo - Class in io.micronaut.jms.info
 
MicronautJmsTracingOpentelemetryModuleInfo() - Constructor for class io.micronaut.jms.info.MicronautJmsTracingOpentelemetryModuleInfo
 

N

name() - Method in record class io.micronaut.jms.listener.JMSTopicSubscription
Returns the value of the name record component.
NON_PERSISTENT - Enum constant in enum class io.micronaut.jms.model.JMSDeliveryMode
Does not require the broker to log the message to stable storage.
notNull(Object, String) - Static method in class io.micronaut.jms.util.Assert
Throws an IllegalArgumentException if the object is null.
notNull(Object, Supplier) - Static method in class io.micronaut.jms.util.Assert
Throws an IllegalArgumentException if the object is null.

O

OBJECT - Enum constant in enum class io.micronaut.jms.model.MessageType
An ObjectMessage to be deserialized to a Serializable.
of(PooledObject) - Static method in class io.micronaut.jms.pool.PooledConnection
 
of(PooledObject) - Static method in class io.micronaut.jms.pool.PooledProducer
 
of(String, String, boolean, boolean, String) - Static method in record class io.micronaut.jms.listener.JMSTopicSubscription
Creates the subscription for a topic listener from its options.
onMessage(Message) - Method in class io.micronaut.jms.listener.MessageHandlerAdapter
 
onMessage(Message) - Method in interface io.micronaut.jms.listener.SessionAwareMessageListener
Not supported: this listener needs the session that consumed the message.
onMessage(Message, Session) - Method in interface io.micronaut.jms.listener.SessionAwareMessageListener
Handles a message.

P

PERSISTENT - Enum constant in enum class io.micronaut.jms.model.JMSDeliveryMode
Requires the broker to log the message to stable storage.
pool - Variable in class io.micronaut.jms.pool.AbstractPool
 
PooledConnection - Class in io.micronaut.jms.pool
Wrapper for Connection that returns it to the JMSConnectionPool with a call to AutoCloseable.close().
PooledConnection(Connection, AbstractPool) - Constructor for class io.micronaut.jms.pool.PooledConnection
 
PooledObject<T> - Class in io.micronaut.jms.pool
Base class for wrappers of pooled objects.
PooledObject(AbstractPool, T) - Constructor for class io.micronaut.jms.pool.PooledObject
 
PooledProducer - Class in io.micronaut.jms.pool
Pooled object for ensuring maximum reuse of MessageProducer objects.
PooledProducer(AbstractPool, MessageProducer) - Constructor for class io.micronaut.jms.pool.PooledProducer
 
PooledSession - Class in io.micronaut.jms.pool
Wrapper for Session that returns it to the pool with a call to AutoCloseable.close().
PooledSession(AbstractPool, Session, MessageProducerPool) - Constructor for class io.micronaut.jms.pool.PooledSession
 
POSITION - Static variable in class io.micronaut.jms.listener.TransactionalJMSListenerSuccessHandler
 
PREFIX - Static variable in interface io.micronaut.jms.activemq.artemis.configuration.properties.ActiveMqArtemisConfigurationProperties
Prefix for ActiveMQ Artemis JMS settings.
PREFIX - Static variable in interface io.micronaut.jms.activemq.classic.configuration.properties.ActiveMqClassicConfigurationProperties
Prefix for ActiveMQ Classic JMS settings.
PREFIX - Static variable in interface io.micronaut.jms.configuration.properties.JMSConfigurationProperties
Prefix for JMS settings.
PREFIX - Static variable in interface io.micronaut.jms.configuration.properties.JMSListenerRecoveryConfiguration
The prefix of the configuration.
PREFIX - Static variable in interface io.micronaut.jms.configuration.properties.JMSProducerSessionConfiguration
The prefix of the configuration.
PREFIX - Static variable in interface io.micronaut.jms.sqs.configuration.properties.SqsConfigurationProperties
Prefix for SQS JMS settings.
priority() - Element in annotation interface io.micronaut.jms.annotations.Queue
The priority, from 0 (lowest) to 9, of the messages that a producer method sends.
priority() - Element in annotation interface io.micronaut.jms.annotations.Topic
The priority, from 0 (lowest) to 9, of the messages that a producer method sends.
process(BeanDefinition, ExecutableMethod) - Method in class io.micronaut.jms.configuration.AbstractJMSListenerMethodProcessor
 
process(JMSDestinationType, String, Message) - Method in class io.micronaut.jms.metrics.JMSMetrics
 
process(JMSDestinationType, String, Message) - Method in interface io.micronaut.jms.observation.JMSMessageObserver
Called before a listener processes a message: before the listener method and the success and error handlers.
process(JMSDestinationType, String, Message) - Method in class io.micronaut.jms.observation.JMSObservations
Starts the observations of a message that a listener processes.
process(JMSDestinationType, String, Message) - Method in class io.micronaut.jms.tracing.opentelemetry.JMSTracing
 
PRODUCER_DURATION - Static variable in class io.micronaut.jms.metrics.JMSMetrics
The name of the timer of the messages that producers send.
PRODUCER_MESSAGES - Static variable in class io.micronaut.jms.metrics.JMSMetrics
The name of the counter of the messages that producers send.
ProducerSessionPool - Class in io.micronaut.jms.pool
Reuses the sessions of producers across sends, instead of opening a connection and a session for each message.
ProducerSessionPool(JMSConnectionPool, int) - Constructor for class io.micronaut.jms.pool.ProducerSessionPool
 
ProducerSessionPool(JMSConnectionPool, int, int, Duration) - Constructor for class io.micronaut.jms.pool.ProducerSessionPool
 
propagatedContext(PropagatedContext) - Method in interface io.micronaut.jms.observation.JMSObservation
Called on the observation of a message that a listener processes, before the listener method runs, to give the propagated context that the listener method and the success and error handlers run in, for example with the span of a trace added, so that it is current while they run and follows them to the threads that the context propagates to.
propagatedContext(List, PropagatedContext) - Static method in class io.micronaut.jms.observation.JMSObservations
Gives observations of a message that a listener processes, in the order of their start, the propagated context to process the message in.

Q

Queue - Annotation Interface in io.micronaut.jms.annotations
Binds a Queue to a method for receiving or sending a Message.
QUEUE - Enum constant in enum class io.micronaut.jms.model.JMSDestinationType
A Queue.

R

receive(String) - Method in class io.micronaut.jms.templates.JmsConsumer
Receives a Message from the broker.
receive(String, Class) - Method in class io.micronaut.jms.templates.JmsConsumer
Receives a Message from the broker and and converts it to an instance of type <T>.
recover() - Method in class io.micronaut.jms.pool.PooledSession
 
register(JMSListener, boolean) - Method in class io.micronaut.jms.listener.JMSListenerRegistry
Registers a new listener to be managed by Micronaut JMS.
register(JMSConnectionPool, JMSDestinationType, String, boolean, int, MessageListener, ExecutorService, boolean, Optional, JMSTopicSubscription) - Method in class io.micronaut.jms.listener.JMSListenerRegistry
Creates and registers a new listener to be managed by Micronaut JMS, optionally with a named topic subscription, on a connection the registry opens.
register(JMSConnectionPool, JMSDestinationType, String, boolean, int, MessageListener, ExecutorService, boolean, Optional, JMSTopicSubscription, int) - Method in class io.micronaut.jms.listener.JMSListenerRegistry
Creates and registers the consumers of a destination, each a listener with its own session, on one connection that the registry opens: a connection from the pool, unless the subscription requires a dedicated connection, in which case it is a new connection from the pool's factory with the subscription's client ID.
register(Connection, JMSDestinationType, String, boolean, int, MessageListener, ExecutorService, boolean, Optional) - Method in class io.micronaut.jms.listener.JMSListenerRegistry
Creates and registers a new listener to be managed by Micronaut JMS.
register(Connection, JMSDestinationType, String, boolean, int, MessageListener, ExecutorService, boolean, Optional, JMSTopicSubscription) - Method in class io.micronaut.jms.listener.JMSListenerRegistry
Creates and registers a new listener to be managed by Micronaut JMS, optionally with a named topic subscription.
registerArgumentBinder(AnnotatedArgumentBinder) - Method in class io.micronaut.jms.bind.JMSArgumentBinderRegistry
Registers an ArgumentBinder.
release(Session, boolean) - Method in class io.micronaut.jms.pool.ProducerSessionPool
Returns a borrowed session.
release(T) - Method in class io.micronaut.jms.pool.AbstractPool
Release the provided object and return it to the pool.
request(Object...) - Method in class io.micronaut.jms.pool.AbstractPool
Requests an object <T> from the pool.
requiresDedicatedConnection() - Method in record class io.micronaut.jms.listener.JMSTopicSubscription
 
reset(PooledObject) - Method in class io.micronaut.jms.pool.JMSConnectionPool
 
reset(PooledObject) - Method in class io.micronaut.jms.pool.MessageProducerPool
 
reset(PooledObject) - Method in class io.micronaut.jms.pool.SessionPool
 
reset(T) - Method in class io.micronaut.jms.pool.AbstractPool
Reset the provided object so it can be returned to the pool for reuse.
rollback() - Method in class io.micronaut.jms.pool.PooledSession
 
run() - Method in class io.micronaut.jms.pool.PooledSession
 

S

send(JMSDestinationType, String) - Method in class io.micronaut.jms.metrics.JMSMetrics
 
send(JMSDestinationType, String) - Method in interface io.micronaut.jms.observation.JMSMessageObserver
Called before a producer sends a message, before the connection is taken from the pool and the message is created, so a send that fails to connect is observed too.
send(JMSDestinationType, String) - Method in class io.micronaut.jms.observation.JMSObservations
Starts the observations of a message that a producer sends, before its connection is taken.
send(JMSDestinationType, String) - Method in class io.micronaut.jms.tracing.opentelemetry.JMSTracing
 
send(Destination, Message, long, MessageHeader...) - Method in class io.micronaut.jms.templates.JmsProducer
Sends the given message to the destination with the given headers.
send(Destination, Message) - Method in class io.micronaut.jms.pool.PooledProducer
 
send(Destination, Message, int, int, long) - Method in class io.micronaut.jms.pool.PooledProducer
 
send(Destination, Message, int, int, long, CompletionListener) - Method in class io.micronaut.jms.pool.PooledProducer
 
send(Destination, Message, CompletionListener) - Method in class io.micronaut.jms.pool.PooledProducer
 
send(Message) - Method in class io.micronaut.jms.pool.PooledProducer
 
send(Message, int, int, long) - Method in class io.micronaut.jms.pool.PooledProducer
 
send(Message, int, int, long, CompletionListener) - Method in class io.micronaut.jms.pool.PooledProducer
 
send(Message, CompletionListener) - Method in class io.micronaut.jms.pool.PooledProducer
 
send(String, T, long, MessageHeader...) - Method in class io.micronaut.jms.templates.JmsProducer
Creates a Message from the body and sends it to the destination with the headers.
send(String, T, JMSDeliveryMode, int, long, MessageHeader...) - Method in class io.micronaut.jms.templates.JmsProducer
Sends a message, serializing the body, with a delivery mode and priority.
send(String, Message, long, MessageHeader...) - Method in class io.micronaut.jms.templates.JmsProducer
Sends the given message to the destination with the given headers.
serialize(Session, Object) - Method in class io.micronaut.jms.serdes.DefaultSerializerDeserializer
 
serialize(Session, Object) - Method in interface io.micronaut.jms.serdes.Serializer
Create a message from the body.
serializer() - Element in annotation interface io.micronaut.jms.annotations.Queue
The name of a Serializer in the bean context to use to serialize an object into a Message when sending.
serializer() - Element in annotation interface io.micronaut.jms.annotations.Topic
The name of a Serializer in the bean context to use to serialize an object into a Message when sending.
Serializer - Interface in io.micronaut.jms.serdes
Serializes an object into a Message.
SessionAwareMessageListener - Interface in io.micronaut.jms.listener
A MessageListener that also receives the Session that consumed the message, so that it can reply, commit or roll back on that session.
SessionPool - Class in io.micronaut.jms.pool
Pool for ensuring maximum reuse of Sessions within an application.
SessionPool(int, int, Connection, MessageProducerPoolFactory) - Constructor for class io.micronaut.jms.pool.SessionPool
 
SessionPoolFactory - Class in io.micronaut.jms.pool
Factory for generating a SessionPool from a Connection.
SessionPoolFactory(MessageProducerPoolFactory) - Constructor for class io.micronaut.jms.pool.SessionPoolFactory
 
setClientID(String) - Method in class io.micronaut.jms.pool.PooledConnection
 
setDeliveryDelay(long) - Method in class io.micronaut.jms.pool.PooledProducer
 
setDeliveryMode(int) - Method in class io.micronaut.jms.pool.PooledProducer
 
setDisableMessageID(boolean) - Method in class io.micronaut.jms.pool.PooledProducer
 
setDisableMessageTimestamp(boolean) - Method in class io.micronaut.jms.pool.PooledProducer
 
setExceptionListener(ExceptionListener) - Method in class io.micronaut.jms.pool.PooledConnection
 
setMessageListener(MessageListener) - Method in class io.micronaut.jms.pool.PooledSession
 
setPriority(int) - Method in class io.micronaut.jms.pool.PooledProducer
 
setTimeToLive(long) - Method in class io.micronaut.jms.pool.PooledProducer
 
shared() - Element in annotation interface io.micronaut.jms.annotations.Topic
Whether the subscription is shared, so its messages are spread over every listener with the same subscription name.
shared() - Method in record class io.micronaut.jms.listener.JMSTopicSubscription
Returns the value of the shared record component.
shutdown() - Method in class io.micronaut.jms.listener.JMSListenerRegistry
Shuts down all registered JMSListeners, returns the pooled connections they were registered with to their pool and closes their dedicated connections, each connection once however many listeners share it.
SqsConfiguration - Class in io.micronaut.jms.sqs.configuration
Generates the AWS SQS JMSConnectionFactory based on the properties provided by SqsConfigurationProperties.
SqsConfiguration() - Constructor for class io.micronaut.jms.sqs.configuration.SqsConfiguration
 
SqsConfigurationProperties - Interface in io.micronaut.jms.sqs.configuration.properties
Configuration properties for creating the AWS SQS JMSConnectionFactory.
sqsJmsConnectionFactory(SqsConfigurationProperties, SqsClient) - Method in class io.micronaut.jms.sqs.configuration.SqsConfiguration
Generates a JMSConnectionFactory bean in the application context.
sqsJmsConnectionFactory(SqsConfigurationProperties, SqsClientBuilder) - Method in class io.micronaut.jms.sqs.configuration.SqsConfiguration
Generates a JMSConnectionFactory bean in the application context.
start() - Method in class io.micronaut.jms.listener.JMSListener
Configures the listener to begin listening for messages and processing them.
start() - Method in class io.micronaut.jms.pool.PooledConnection
 
stop() - Method in class io.micronaut.jms.listener.JMSListener
Stops the listener from consuming messages and attempts to clean up any resources used.
stop() - Method in class io.micronaut.jms.pool.PooledConnection
 
STREAM - Enum constant in enum class io.micronaut.jms.model.MessageType
A StreamMessage.
subscription() - Element in annotation interface io.micronaut.jms.annotations.Topic
The name of the subscription.
successHandlers() - Element in annotation interface io.micronaut.jms.annotations.JMSListener
The success handlers to be injected into the message handling logic for all Queue or Topic methods.
successHandlers() - Element in annotation interface io.micronaut.jms.annotations.Queue
The success handlers to be injected into the message handling logic.
successHandlers() - Element in annotation interface io.micronaut.jms.annotations.Topic
The success handlers to be injected into the message handling logic.

T

TEXT - Enum constant in enum class io.micronaut.jms.model.MessageType
A TextMessage to be deserialized to a String.
Topic - Annotation Interface in io.micronaut.jms.annotations
Annotation to bind a Topic to a method for receiving or sending a Message.
TOPIC - Enum constant in enum class io.micronaut.jms.model.JMSDestinationType
A Topic.
toString() - Method in class io.micronaut.jms.bind.JMSArgumentBinderRegistry
 
toString() - Method in class io.micronaut.jms.listener.JMSListener
 
toString() - Method in record class io.micronaut.jms.listener.JMSTopicSubscription
Returns a string representation of this record class.
toString() - Method in class io.micronaut.jms.model.MessageHeader
 
toString() - Method in class io.micronaut.jms.pool.JMSConnectionPool
 
toString() - Method in class io.micronaut.jms.pool.MessageProducerPool
 
toString() - Method in class io.micronaut.jms.pool.PooledConnection
 
toString() - Method in class io.micronaut.jms.pool.PooledProducer
 
toString() - Method in class io.micronaut.jms.pool.PooledSession
 
toString() - Method in class io.micronaut.jms.pool.SessionPool
 
toString() - Method in class io.micronaut.jms.templates.JmsConsumer
 
toString() - Method in class io.micronaut.jms.templates.JmsProducer
 
transacted() - Element in annotation interface io.micronaut.jms.annotations.Queue
Whether the session is transacted.
transacted() - Element in annotation interface io.micronaut.jms.annotations.Topic
Whether the session is transacted.
TransactionalJMSListenerErrorHandler - Class in io.micronaut.jms.listener
Attempts to rollback a transaction on the given Session.
TransactionalJMSListenerErrorHandler() - Constructor for class io.micronaut.jms.listener.TransactionalJMSListenerErrorHandler
 
TransactionalJMSListenerSuccessHandler - Class in io.micronaut.jms.listener
Commits a JMS transaction upon successful handling of a message.
TransactionalJMSListenerSuccessHandler() - Constructor for class io.micronaut.jms.listener.TransactionalJMSListenerSuccessHandler
 

U

UNKNOWN - Enum constant in enum class io.micronaut.jms.model.MessageType
The default case if no known Message subtype is known for the incoming message.
unregisterArgumentBinder(AnnotatedArgumentBinder) - Method in class io.micronaut.jms.bind.JMSArgumentBinderRegistry
Remove a registered binder.
unsubscribe(String) - Method in class io.micronaut.jms.pool.PooledSession
 

V

value() - Element in annotation interface io.micronaut.jms.annotations.JMSConnectionFactory
Name to identify the ConnectionFactory bean in the context.
value() - Element in annotation interface io.micronaut.jms.annotations.JMSListener
Name of the ConnectionFactory bean in the context to use to configure the JMSListener.
value() - Element in annotation interface io.micronaut.jms.annotations.JMSProducer
Name of the ConnectionFactory bean in the context to use to configure the JMSListener.
value() - Element in annotation interface io.micronaut.jms.annotations.Queue
The name of the queue to target.
value() - Element in annotation interface io.micronaut.jms.annotations.Topic
The name of the topic to target.
valueOf(String) - Static method in enum class io.micronaut.jms.model.JMSDeliveryMode
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.micronaut.jms.model.JMSDestinationType
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.micronaut.jms.model.MessageType
Returns the enum constant of this class with the specified name.
values() - Static method in enum class io.micronaut.jms.model.JMSDeliveryMode
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.micronaut.jms.model.JMSDestinationType
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.micronaut.jms.model.MessageType
Returns an array containing the constants of this enum class, in the order they are declared.
A B C D E F G H I J L M N O P Q R S T U V 
All Classes and Interfaces|All Packages|Constant Field Values