Index
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 toJMSListener
. - 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 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
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 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
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 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
- 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 withMessageBody
. - 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 withMessageHeader
. - 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 withMessage
. - DefaultMessageArgumentBinder(ConversionService) - Constructor for class io.micronaut.jms.bind.DefaultMessageArgumentBinder
-
Constructor.
- DefaultSerializerDeserializer - Class in io.micronaut.jms.serdes
-
Default implementation of
Serializer
andDeserializer
. - 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
- 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 givenmessage
. - fromObject(Object) - Static method in enum class io.micronaut.jms.model.MessageType
-
Determine the
MessageType
corresponding 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
- 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 givenmessage
. - getInitialPoolSize() - Method in interface io.micronaut.jms.configuration.properties.JMSConfigurationProperties
- getMaxPoolSize() - Method in interface io.micronaut.jms.configuration.properties.JMSConfigurationProperties
- 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 aSession
. - getSessionPool(Connection) - Method in class io.micronaut.jms.pool.SessionPoolFactory
-
Returns a
SessionPool
from 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.
- 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 ofArgumentBinder
capable of binding aMessage
. - 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 registeredConnectionFactory
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 ofConnection
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
MessageListener
s created by theJMSListener
andAbstractJMSListenerMethodProcessor
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
JMSListener
s 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 withQueue
. - JMSQueueListenerMethodProcessor(BeanContext, JMSArgumentBinderRegistry) - Constructor for class io.micronaut.jms.configuration.JMSQueueListenerMethodProcessor
- JMSTopicListenerMethodProcessor - Class in io.micronaut.jms.configuration
-
Registers a
JMSListener
for methods annotated withTopic
. - 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
JMSListener
s. - 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 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
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
Message
s. - MessageHandlerAdapter<T> - Class in io.micronaut.jms.listener
-
Decorator for converting between
MessageListener
andMessageHandler
. - 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
MessageProducer
s. - MessageProducerPool(int, int, Session) - Constructor for class io.micronaut.jms.pool.MessageProducerPool
- MessageProducerPoolFactory - Class in io.micronaut.jms.pool
-
Factory for generating
MessageProducerPool
from 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
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 aSerializable
. - 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 theJMSConnectionPool
with a call toAutoCloseable.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 toAutoCloseable.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 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
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 thedestination
with the givenheaders
. - send(String, Message, long, MessageHeader...) - Method in class io.micronaut.jms.templates.JmsProducer
-
Sends the given
message
to thedestination
with the givenheaders
. - send(String, T, long, MessageHeader...) - Method in class io.micronaut.jms.templates.JmsProducer
-
Creates a
Message
from thebody
and sends it to thedestination
with theheaders
. - 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 aMessage
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 aMessage
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
Session
s 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 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
- shutdown() - Method in class io.micronaut.jms.listener.JMSListenerRegistry
-
Shuts down all registered
JMSListener
s. - SqsConfiguration - Class in io.micronaut.jms.sqs.configuration
-
Generates the AWS SQS
JMSConnectionFactory
based 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
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
- 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 aString
. - Topic - Annotation Interface in io.micronaut.jms.annotations
-
Annotation to bind a
Topic
to 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.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 theJMSListener
. - value() - Element in annotation interface io.micronaut.jms.annotations.JMSProducer
-
Name of the
ConnectionFactory
bean 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