A B C D E F G H I J L M N O P Q R S T U V

A

AbstractJmsArgumentBinder<A extends java.lang.annotation.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 java.lang.annotation.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

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.

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

C

close() - Method in class io.micronaut.jms.pool.PooledObject

commit() - Method in class io.micronaut.jms.pool.PooledSession

ConcurrentMessageHandler<T> - Class in io.micronaut.jms.listener

A MessageHandler decorator that wraps a delegate implementation in an ExecutorService to handle many incoming messages concurrently on different threads.

ConcurrentMessageHandler(MessageHandler<T>, ExecutorService) - Constructor for class io.micronaut.jms.listener.ConcurrentMessageHandler

Allows for concurrent handling of messages by handing of the logic to a delegate MessageHandler but wrapping those calls within an Executor.execute(Runnable).

ConcurrentMessageHandler(MessageHandler<T>) - Constructor for class io.micronaut.jms.listener.ConcurrentMessageHandler

Submits incoming handling requests on a single threaded executor to avoid blocking the main thread.

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(String, String) - Method in class io.micronaut.jms.pool.JMSConnectionPool

createContext(String, String, int) - Method in class io.micronaut.jms.pool.JMSConnectionPool

createContext(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(boolean, int) - Method in class io.micronaut.jms.pool.PooledConnection

createSession(int) - Method in class io.micronaut.jms.pool.PooledConnection

createSession() - 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

DefaultBodyArgumentBinder - Class in io.micronaut.jms.bind

Binds a Message to a method argument annotated with Body.

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 Header.

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, Class<T>) - Method in 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 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

F

findArgumentBinder(Argument<T>, Message) - Method in class io.micronaut.jms.bind.JMSArgumentBinderRegistry

from(int) - Static method in enum io.micronaut.jms.model.JMSDeliveryMode

fromMessage(Message) - Static method in enum io.micronaut.jms.model.MessageType

Determine the MessageType corresponding to the given message.

fromObject(Object) - Static method in enum 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<T>) - Method in class io.micronaut.jms.configuration.AbstractJMSListenerMethodProcessor

getExecutorService(AnnotationValue<Queue>) - Method in class io.micronaut.jms.configuration.JMSQueueListenerMethodProcessor

getExecutorService(AnnotationValue<Topic>) - Method in class io.micronaut.jms.configuration.JMSTopicListenerMethodProcessor

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

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

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.

H

handle(T) - Method in class io.micronaut.jms.listener.ConcurrentMessageHandler

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 Type 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 in io.micronaut.jms.model

The different persistence modes of JMS Brokers.

JMSDestinationType - Enum 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 - Annotation Type in io.micronaut.jms.annotations

Declares a class for post-processing.

JMSListenerContainer<T> - Class in io.micronaut.jms.listener

Sets up and manages MessageListeners created by the JMSListener and AbstractJMSListenerMethodProcessor processing.

JMSListenerContainer(JMSConnectionPool, JMSDestinationType, int) - Constructor for class io.micronaut.jms.listener.JMSListenerContainer

JMSListenerContainer(JMSConnectionPool, JMSDestinationType, int, int) - Constructor for class io.micronaut.jms.listener.JMSListenerContainer

JMSListenerContainerFactory - Class in io.micronaut.jms.listener

Generates and tracks JMSListenerContainer within the Bean Context.

JMSListenerContainerFactory() - Constructor for class io.micronaut.jms.listener.JMSListenerContainerFactory

JMSProducer - Annotation Type in io.micronaut.jms.annotations

Declares a class for post-processing.

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

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 JMSListenerContainer 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 JMSListenerContainer 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

M

maxSize - Variable in class io.micronaut.jms.pool.AbstractPool

Message - Annotation Type 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

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

MessageType - Enum in io.micronaut.jms.model

The underlying type of a Message mapped to the corresponding class.

N

notNull(Object, String) - Static method in class io.micronaut.jms.util.Assert

Throws an IllegalArgumentException if the object is null.

notNull(Object, Supplier<String>) - Static method in class io.micronaut.jms.util.Assert

Throws an IllegalArgumentException if the object is null.

O

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

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

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<?>, ExecutableMethod<?, ?>) - Method in class io.micronaut.jms.configuration.AbstractJMSListenerMethodProcessor

process(BeanDefinition<?>, BeanContext) - Method in class io.micronaut.jms.configuration.JMSConnectionFactoryBeanProcessor

Q

Queue - Annotation Type in io.micronaut.jms.annotations

Binds a Queue to a method for receiving or sending a Message.

R

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>.

receive(String) - Method in class io.micronaut.jms.templates.JmsConsumer

Receives a Message from the broker.

recover() - Method in class io.micronaut.jms.pool.PooledSession

registerArgumentBinder(AbstractAnnotatedArgumentBinder<?, ?, Message>) - Method in class io.micronaut.jms.bind.JMSArgumentBinderRegistry

Registers an ArgumentBinder.

registerListener(String, MessageHandler<T>, Class<T>) - Method in class io.micronaut.jms.listener.JMSListenerContainer

Registers a JMSListenerContainer with default concurrency.

registerListener(String, MessageListener, Class<T>, boolean, int) - Method in class io.micronaut.jms.listener.JMSListenerContainer

Internal method used by the JMSListenerContainerFactory for registering new listeners.

registerListener(JMSConnectionPool, String, MessageHandler<T>, Class<T>, JMSDestinationType) - Method in class io.micronaut.jms.listener.JMSListenerContainerFactory

Generates a new JMSListenerContainer and registers the provided MessageHandler as the receiving executable method.

registerListener(JMSConnectionPool, String, MessageListener, Class<T>, boolean, int, JMSDestinationType) - Method in class io.micronaut.jms.listener.JMSListenerContainerFactory

Generates a new JMSListenerContainer and registers the provided MessageListener as the receiving executable method.

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(T) - Method in class io.micronaut.jms.pool.AbstractPool

Reset the provided object so it can be returned to the pool for reuse.

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

rollback() - Method in class io.micronaut.jms.pool.PooledSession

run() - Method in class io.micronaut.jms.pool.PooledSession

S

send(Message) - Method in class io.micronaut.jms.pool.PooledProducer

send(Message, int, int, long) - Method in class io.micronaut.jms.pool.PooledProducer

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(Message, CompletionListener) - Method in class io.micronaut.jms.pool.PooledProducer

send(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(Destination, Message, int, int, long, CompletionListener) - Method in class io.micronaut.jms.pool.PooledProducer

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(String, Message, MessageHeader...) - Method in class io.micronaut.jms.templates.JmsProducer

Sends the given message to the destination with the given headers.

send(Destination, Message, MessageHeader...) - Method in class io.micronaut.jms.templates.JmsProducer

Sends the given message to the destination with the given headers.

serialize(Session, Object) - Method in class io.micronaut.jms.serdes.DefaultSerializerDeserializer

serialize(Session, Object) - Method in interface io.micronaut.jms.serdes.Serializer

Create a message from the body.

Serializer - 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

Closes the MessageHandler and terminates the ConcurrentMessageHandler.executorService.

shutdown() - Method in class io.micronaut.jms.listener.JMSListenerContainer

Safely shuts down all open connections linked to the listener container.

shutdown() - Method in class io.micronaut.jms.listener.JMSListenerContainerFactory

Shuts down the listeners registered with this factory.

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, AmazonSQS) - Method in class io.micronaut.jms.sqs.configuration.SqsConfiguration

Generates a JMSConnectionFactory bean in the application context.

start() - Method in class io.micronaut.jms.pool.PooledConnection

stop() - Method in class io.micronaut.jms.pool.PooledConnection

T

Topic - Annotation Type in io.micronaut.jms.annotations

Annotation to bind a Topic to a method for receiving or sending a Message.

toString() - Method in class io.micronaut.jms.bind.JMSArgumentBinderRegistry

toString() - Method in class io.micronaut.jms.listener.JMSListenerContainer

toString() - Method in class io.micronaut.jms.listener.JMSListenerContainerFactory

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

U

unregisterArgumentBinder(AbstractAnnotatedArgumentBinder<?, ?, Message>) - Method in class io.micronaut.jms.bind.JMSArgumentBinderRegistry

Remove a registered binder.

unsubscribe(String) - Method in class io.micronaut.jms.pool.PooledSession

V

valueOf(String) - Static method in enum io.micronaut.jms.model.JMSDeliveryMode

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum io.micronaut.jms.model.JMSDestinationType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum io.micronaut.jms.model.MessageType

Returns the enum constant of this type with the specified name.

values() - Static method in enum io.micronaut.jms.model.JMSDeliveryMode

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum io.micronaut.jms.model.JMSDestinationType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum io.micronaut.jms.model.MessageType

Returns an array containing the constants of this enum type, 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