Index
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
ExecutableMethodProcessorfor annotations related toJMSListener. - 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
JMSConnectionFactorybased on the properties provided byActiveMqArtemisConfigurationProperties. - 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
JMSConnectionFactorybean in the application context. - ActiveMqClassicConfiguration - Class in io.micronaut.jms.activemq.classic.configuration
-
Generates the ActiveMQ Classic
JMSConnectionFactorybased on the properties provided byActiveMqClassicConfigurationProperties. - 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
JMSConnectionFactorybean 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
keywith the value given withvalue, 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
BytesMessageto 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
JMSListenerconsumes 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
clientIdrecord 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
ConnectionFactorybean. - CONNECTION_FACTORY_BEAN_NAME - Static variable in class io.micronaut.jms.activemq.classic.configuration.ActiveMqClassicConfiguration
-
Name of the ActiveMQ Classic
ConnectionFactorybean. - CONNECTION_FACTORY_BEAN_NAME - Static variable in class io.micronaut.jms.sqs.configuration.SqsConfiguration
-
Name of the SQS
ConnectionFactorybean. - 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
Messageto a method argument annotated withMessageBody. - DefaultBodyArgumentBinder(ConversionService, Deserializer) - Constructor for class io.micronaut.jms.bind.DefaultBodyArgumentBinder
-
Constructor.
- DefaultHeaderArgumentBinder - Class in io.micronaut.jms.bind
-
Binds headers from a
Messageto a method argument annotated withMessageHeader. - DefaultHeaderArgumentBinder(ConversionService) - Constructor for class io.micronaut.jms.bind.DefaultHeaderArgumentBinder
-
Constructor.
- DefaultMessageArgumentBinder - Class in io.micronaut.jms.bind
-
Binds a
Messageto a method argument annotated withMessage. - DefaultMessageArgumentBinder(ConversionService) - Constructor for class io.micronaut.jms.bind.DefaultMessageArgumentBinder
-
Constructor.
- DefaultSerializerDeserializer - Class in io.micronaut.jms.serdes
-
Default implementation of
SerializerandDeserializer. - 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
Deserializerin the bean context that a listener method uses to convert eachMessageof the queue into its@MessageBodyargument. - deserializer() - Element in annotation interface io.micronaut.jms.annotations.Topic
-
The name of a
Deserializerin the bean context that a listener method uses to convert eachMessageof the topic into its@MessageBodyargument. - Deserializer - Interface in io.micronaut.jms.serdes
-
Extracts a
Messagebody 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
durablerecord 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
- 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
MessageTypecorresponding to the givenmessage. - fromObject(Object) - Static method in enum class io.micronaut.jms.model.MessageType
-
Determine the
MessageTypecorresponding to the givenmessage.
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
headerNamefrom the givenmessage. - 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
- 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
- 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
MessageProducerPoolgiven aSession. - getResult() - Method in class io.micronaut.jms.health.JMSHealthIndicator
- getSessionPool(Connection) - Method in class io.micronaut.jms.pool.SessionPoolFactory
-
Returns a
SessionPoolfrom the providedconnection. - 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
Messageinstances 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
ArgumentBinderRegistryfor all implementations ofArgumentBindercapable of binding aMessage. - 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
ConnectionFactoryto ensure maximum reuse ofConnectioninstances. - 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 theJMSListenerandAbstractJMSListenerMethodProcessorprocessing. - 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
JMSListenerinstance. - JMSListener(Session, MessageListener, JMSDestinationType, String, ExecutorService, Optional, JMSTopicSubscription) - Constructor for class io.micronaut.jms.listener.JMSListener
-
Creates a
JMSListenerinstance, 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
JMSMessageObserverstarted. - 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
JMSListenerfor methods annotated withQueue. - JMSQueueListenerMethodProcessor(BeanContext, JMSArgumentBinderRegistry) - Constructor for class io.micronaut.jms.configuration.JMSQueueListenerMethodProcessor
- JMSTopicListenerMethodProcessor - Class in io.micronaut.jms.configuration
-
Registers a
JMSListenerfor methods annotated withTopic. - 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
JMSTopicSubscriptionrecord 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
MapMessageto be deserialized to aMap. - 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
MessageBodyannotation. - 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
JMSDeliveryModeor aDeliveryModevalue, passed toMessageProducer.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
MessageListenerandMessageHandler. - 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
MessageHeaderannotation. - 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
MessageProducerPoolfrom aSession. - 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
Messagemapped 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
namerecord 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
ObjectMessageto be deserialized to aSerializable. - 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
Connectionthat returns it to theJMSConnectionPoolwith a call toAutoCloseable.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
MessageProducerobjects. - PooledProducer(AbstractPool, MessageProducer) - Constructor for class io.micronaut.jms.pool.PooledProducer
- PooledSession - Class in io.micronaut.jms.pool
-
Wrapper for
Sessionthat returns it to the pool with a call toAutoCloseable.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
Queueto a method for receiving or sending aMessage. - 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
Messagefrom the broker. - receive(String, Class) - Method in class io.micronaut.jms.templates.JmsConsumer
-
Receives a
Messagefrom 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
messageto thedestinationwith the givenheaders. - 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
Messagefrom thebodyand sends it to thedestinationwith theheaders. - 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
messageto thedestinationwith the givenheaders. - 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
Serializerin the bean context to use to serialize an object into aMessagewhen sending. - serializer() - Element in annotation interface io.micronaut.jms.annotations.Topic
-
The name of a
Serializerin the bean context to use to serialize an object into aMessagewhen sending. - Serializer - Interface in io.micronaut.jms.serdes
-
Serializes an object into a
Message. - SessionAwareMessageListener - Interface in io.micronaut.jms.listener
-
A
MessageListenerthat also receives theSessionthat 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
SessionPoolfrom aConnection. - 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
sharedrecord 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
JMSConnectionFactorybased on the properties provided bySqsConfigurationProperties. - 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
JMSConnectionFactorybean in the application context. - sqsJmsConnectionFactory(SqsConfigurationProperties, SqsClientBuilder) - Method in class io.micronaut.jms.sqs.configuration.SqsConfiguration
-
Generates a
JMSConnectionFactorybean 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
- 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
TextMessageto be deserialized to aString. - Topic - Annotation Interface in io.micronaut.jms.annotations
-
Annotation to bind a
Topicto a method for receiving or sending aMessage. - 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
Messagesubtype 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
ConnectionFactorybean in the context. - value() - Element in annotation interface io.micronaut.jms.annotations.JMSListener
-
Name of the
ConnectionFactorybean in the context to use to configure theJMSListener. - value() - Element in annotation interface io.micronaut.jms.annotations.JMSProducer
-
Name of the
ConnectionFactorybean in the context to use to configure theJMSListener. - 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.
All Classes and Interfaces|All Packages|Constant Field Values
JMSListenerRegistry(Collection, Collection, Collection, JMSListenerRecoveryConfiguration)instead