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
 
concurrency() - Element in annotation interface io.micronaut.jms.annotations.Queue
Deprecated.
since 3.0.0, to align the implementation with the JMS model and the messaging libraries' presumptions.
ConcurrentMessageHandler<T> - Class in io.micronaut.jms.listener
Deprecated.
as of 2.1.1
ConcurrentMessageHandler(MessageHandler<T>) - Constructor for class io.micronaut.jms.listener.ConcurrentMessageHandler
Deprecated.
Submits incoming handling requests on a single threaded executor to avoid blocking the main thread.
ConcurrentMessageHandler(MessageHandler<T>, ExecutorService) - Constructor for class io.micronaut.jms.listener.ConcurrentMessageHandler
Deprecated.
Allows for concurrent handling of messages by handing of the logic to a delegate MessageHandler but wrapping those calls within an Executor.execute(Runnable).
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.
executor() - Element in annotation interface io.micronaut.jms.annotations.Queue
Deprecated.
since 3.0.0, to align the implementation with the JMS model and the messaging libraries' presumptions.
executor() - Element in annotation interface io.micronaut.jms.annotations.Topic
Deprecated.
since 3.0.0, to align the implementation with the JMS model and the messaging libraries' presumptions.

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.
getRegisteredListener(String) - Method in class io.micronaut.jms.listener.JMSListenerContainerFactory
Deprecated.
The JMSListenerContainer that is listening to the given destination.
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 class io.micronaut.jms.listener.ConcurrentMessageHandler
Deprecated.
 
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.
JMSListenerContainer<T> - Class in io.micronaut.jms.listener
Deprecated.
as of 2.1.1
JMSListenerContainer(JMSConnectionPool, JMSDestinationType, int) - Constructor for class io.micronaut.jms.listener.JMSListenerContainer
Deprecated.
 
JMSListenerContainer(JMSConnectionPool, JMSDestinationType, int, int) - Constructor for class io.micronaut.jms.listener.JMSListenerContainer
Deprecated.
 
JMSListenerContainerFactory - Class in io.micronaut.jms.listener
Deprecated.
as of 2.1.1
JMSListenerContainerFactory() - Constructor for class io.micronaut.jms.listener.JMSListenerContainerFactory
Deprecated.
 
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
 
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.
registerListener(JMSConnectionPool, String, MessageHandler<T>, Class<T>, JMSDestinationType) - Method in class io.micronaut.jms.listener.JMSListenerContainerFactory
Deprecated.
Generates a new JMSListenerContainer and registers the provided MessageHandler as the receiving executable method.
registerListener(JMSConnectionPool, String, MessageListener, Class<T>, boolean, int, JMSDestinationType, Optional<String>) - Method in class io.micronaut.jms.listener.JMSListenerContainerFactory
Deprecated.
Generates a new JMSListenerContainer and registers the provided MessageListener as the receiving executable method.
registerListener(String, MessageHandler<T>, Class<T>) - Method in class io.micronaut.jms.listener.JMSListenerContainer
Deprecated.
Registers a JMSListenerContainer with default concurrency.
registerListener(String, MessageListener, Class<T>, boolean, int, Optional<String>) - Method in class io.micronaut.jms.listener.JMSListenerContainer
Deprecated.
Internal method used by the JMSListenerContainerFactory for registering new listeners.
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(String, Message, MessageHeader...) - Method in class io.micronaut.jms.templates.JmsProducer
Sends the given message to the destination with the given headers.
send(String, T, 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, MessageHeader...) - Method in class io.micronaut.jms.templates.JmsProducer
Sends the given message to the destination with the given headers.
send(Destination, Message) - Method in class io.micronaut.jms.pool.PooledProducer
 
send(Destination, Message, int, int, long) - Method in class io.micronaut.jms.pool.PooledProducer
 
send(Destination, Message, int, int, long, CompletionListener) - Method in class io.micronaut.jms.pool.PooledProducer
 
send(Destination, Message, CompletionListener) - Method in class io.micronaut.jms.pool.PooledProducer
 
send(Message) - Method in class io.micronaut.jms.pool.PooledProducer
 
send(Message, int, int, long) - Method in class io.micronaut.jms.pool.PooledProducer
 
send(Message, int, int, long, CompletionListener) - Method in class io.micronaut.jms.pool.PooledProducer
 
send(Message, CompletionListener) - Method in class io.micronaut.jms.pool.PooledProducer
 
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.ConcurrentMessageHandler
Deprecated.
Closes the MessageHandler and terminates the ConcurrentMessageHandler.executorService.
shutdown() - Method in class io.micronaut.jms.listener.JMSListenerContainer
Deprecated.
Safely shuts down all open connections linked to the listener container.
shutdown() - Method in class io.micronaut.jms.listener.JMSListenerContainerFactory
Deprecated.
Shuts down the listeners registered with this factory.
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.listener.JMSListenerContainer
Deprecated.
 
toString() - Method in class io.micronaut.jms.listener.JMSListenerContainerFactory
Deprecated.
 
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