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 extends Annotation> - 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 extends Annotation> - Class in io.micronaut.jms.configuration
Abstract ExecutableMethodProcessor for annotations related to JMSListener.
AbstractJMSListenerMethodProcessor(BeanContext, JMSArgumentBinderRegistry, Class<T>) - Constructor for class io.micronaut.jms.configuration.AbstractJMSListenerMethodProcessor
 
AbstractPool<T extends PooledObject<?>> - 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.
addErrorHandlers(JMSListenerErrorHandler...) - Method in class io.micronaut.jms.listener.JMSListener
 
addErrorHandlers(Collection<? extends JMSListenerErrorHandler>) - Method in class io.micronaut.jms.listener.JMSListener
 
addSuccessHandlers(JMSListenerSuccessHandler...) - Method in class io.micronaut.jms.listener.JMSListener
 
addSuccessHandlers(Collection<? extends JMSListenerSuccessHandler>) - 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
 
bind(ArgumentConversionContext<Object>, Message) - Method in class io.micronaut.jms.bind.DefaultBodyArgumentBinder
 
bind(ArgumentConversionContext<Object>, Message) - Method in class io.micronaut.jms.bind.DefaultHeaderArgumentBinder
 
bind(ArgumentConversionContext<Object>, Message) - Method in class io.micronaut.jms.bind.DefaultMessageArgumentBinder
 
bind(ArgumentConversionContext<Object>, Message) - Method in class io.micronaut.jms.bind.MessageBodyHeaderArgumentBinder
 
bind(ArgumentConversionContext<Object>, Message) - Method in class io.micronaut.jms.bind.MessageHeaderArgumentBinder
 
BYTES - Enum constant in enum class io.micronaut.jms.model.MessageType
A BytesMessage to be deserialized to a byte array.

C

close() - Method in class io.micronaut.jms.pool.PooledObject
 
commit() - Method in class io.micronaut.jms.pool.PooledSession
 
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.
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

decode(String) - Static method in class io.micronaut.jms.util.HeaderNameUtils
 
DEFAULT_POSITION - Static variable in interface io.micronaut.jms.listener.JMSListenerSuccessHandler
 
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
 
deserialize(Message) - Method in interface io.micronaut.jms.serdes.Deserializer
Extract the body of the message into a sensible type.
deserialize(Message, Class<T>) - Method in class io.micronaut.jms.serdes.DefaultSerializerDeserializer
 
deserialize(Message, Class<T>) - Method in interface io.micronaut.jms.serdes.Deserializer
Extract the body of the message into the specified type.
Deserializer - Interface in io.micronaut.jms.serdes
Extracts a Message body to an instance of the specified type.

E

encode(String) - Static method in class io.micronaut.jms.util.HeaderNameUtils
 
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<T>) - 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
 
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<Queue>) - Method in class io.micronaut.jms.configuration.JMSQueueListenerMethodProcessor
 
getExecutorService(AnnotationValue<Topic>) - Method in class io.micronaut.jms.configuration.JMSTopicListenerMethodProcessor
 
getExecutorService(AnnotationValue<T>) - Method in class io.micronaut.jms.configuration.AbstractJMSListenerMethodProcessor
 
getHeader(String, Message, Class<T>) - Static method in class io.micronaut.jms.model.JMSHeaders
Attempts to retrieve the value of the header given by headerName from the given message.
getInitialPoolSize() - Method in interface io.micronaut.jms.configuration.properties.JMSConfigurationProperties
The initial size of the JMSConnectionPool, SessionPool, and MessageProducerPool.
getMaxPoolSize() - Method in interface io.micronaut.jms.configuration.properties.JMSConfigurationProperties
The maximum size of the JMSConnectionPool, SessionPool, and MessageProducerPool.
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
 
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.
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.
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.
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
 
intercept(MethodInvocationContext<Object, Object>) - 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.listener - package io.micronaut.jms.listener
JMS message listener classes.
io.micronaut.jms.model - package io.micronaut.jms.model
Enum classes.
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.util - package io.micronaut.jms.util
Utility classes.
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.sqs.configuration.properties.SqsConfigurationProperties
Whether SQS is active.
isJMSHeader(String) - Static method in class io.micronaut.jms.model.JMSHeaders
 
isTrue(boolean, Supplier<String>) - Static method in class io.micronaut.jms.util.Assert
Throws an IllegalArgumentException if the boolean expression is false.

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, 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.
JMSConnectionFactoryBeanProcessor - Class in io.micronaut.jms.configuration
Creates a JMSConnectionPool from each registered ConnectionFactory in the context.
JMSConnectionFactoryBeanProcessor(JMSConfigurationProperties) - Constructor for class io.micronaut.jms.configuration.JMSConnectionFactoryBeanProcessor
 
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.
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<String>) - Constructor for class io.micronaut.jms.listener.JMSListener
Creates a JMSListener instance.
JMSListenerErrorHandler - Interface in io.micronaut.jms.listener
Handles any errors thrown when handling a message on a JMSListener.
JMSListenerRegistry - Class in io.micronaut.jms.listener
Registry for all JMSListeners managed by Micronaut JMS.
JMSListenerRegistry(Collection<GlobalJMSListenerSuccessHandler>, Collection<GlobalJMSListenerErrorHandler>) - 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.
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 - 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
 
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
 

L

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.
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<T>, Class<T>) - Constructor for class io.micronaut.jms.listener.MessageHandlerAdapter
 
MessageHandlerAdapter(MessageHandler<T>, Class<T>, 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.
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.

N

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, Supplier<String>) - Static method in class io.micronaut.jms.util.Assert
Throws an IllegalArgumentException if the object is null.
notNull(Object, String) - 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<Connection>) - Static method in class io.micronaut.jms.pool.PooledConnection
 
of(PooledObject<MessageProducer>) - Static method in class io.micronaut.jms.pool.PooledProducer
 
onMessage(Message) - Method in class io.micronaut.jms.listener.MessageHandlerAdapter
 

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<PooledObject<Connection>>) - 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<PooledObject<T>>, 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<PooledObject<MessageProducer>>, 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<PooledObject<Session>>, 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.sqs.configuration.properties.SqsConfigurationProperties
Prefix for SQS JMS settings.
process(BeanDefinition<?>, BeanContext) - Method in class io.micronaut.jms.configuration.JMSConnectionFactoryBeanProcessor
 
process(BeanDefinition<?>, ExecutableMethod<?, ?>) - Method in class io.micronaut.jms.configuration.AbstractJMSListenerMethodProcessor
 

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<T>) - 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(Connection, JMSDestinationType, String, boolean, int, MessageListener, ExecutorService, boolean, Optional<String>) - Method in class io.micronaut.jms.listener.JMSListenerRegistry
Creates and registers a new listener to be managed by Micronaut JMS.
registerArgumentBinder(AnnotatedArgumentBinder<?, ?, ?>) - Method in class io.micronaut.jms.bind.JMSArgumentBinderRegistry
Registers an ArgumentBinder.
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.
reset(PooledObject<Connection>) - Method in class io.micronaut.jms.pool.JMSConnectionPool
 
reset(PooledObject<MessageProducer>) - Method in class io.micronaut.jms.pool.MessageProducerPool
 
reset(PooledObject<Session>) - 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(Destination, Message, long, MessageHeader...) - Method in class io.micronaut.jms.templates.JmsProducer
Sends the given message to the destination with the given headers.
send(String, Message, long, MessageHeader...) - Method in class io.micronaut.jms.templates.JmsProducer
Sends the given message to the destination with the given headers.
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(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
 
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.
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
 
shutdown() - Method in class io.micronaut.jms.listener.JMSListenerRegistry
Shuts down all registered JMSListeners.
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.
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.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 message receipt is transacted.
transacted() - Element in annotation interface io.micronaut.jms.annotations.Topic
Whether message receipt 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