All Classes and Interfaces

Class
Description
 
Builder implementation for creating a DefaultJmsAttributes instance
Base implementation of a PoolingConnectionProvider for JmsConnections
Abstract builder for AbstractJmsConnectionProvider subclasses.
 
Callback for Acknowledge related tasks
Declares the kind of Acknowledgement mode supported.
Is used to override the metadata generated by
Defines a JndiNameResolver that uses a cache in order to store the already resolved names.
Container group for connection factory cache parameters
Provides the configuration elements required to configure a JmsCachingConnectionFactory
Defines the strategy to be used for caching of Sessions and Connections
Composite pattern implementation for ExceptionListener.
Declares the kind of Acknowledgement mode supported for consumer operations.
Implementations of this interface provide a way to configure custom properties for a consumer based on the destination kind from which consumption will occurr
Default implementation of CachingConfiguration that not only enables caching but also provides default values for all the configurable parameters
Common connection parameters for the AbstractJmsConnectionProvider
Contains all the metadata of a JMS Message, it carries information such as the Headers, the Properties and the required ID for performing an ACK on the Message.
Default JmsAttributesBuilder implementation
JmsAttributesBuilderFactory default internal implementation.
Base configuration for JmsConnector
Delegates to the default implementation.
Contains the parameters that can override the default values for publishing a Message
Configuration parameters for consuming messages from a JMS Queue or Topics
Representation of a Destination that contains it's identifier name and kind of Destination
Default implementation of JmsListenerLock based in the usage of Semaphore to support the capability of locking and unlocking the listener from different threads
Default implementation of JmsListenerLockFactory
Enables the creation of an outgoing Message.
Configuration parameters for sending messages to a JMS Queue or Topic
A default JmsResourceReleaser implementation in which the cleanup is performed in a silent way.
Enables the creation of an outgoing Message along with the response configuration.
Wrapper element for a JMS Session that relates the session with its AckID
Default implementation of a reconnection manager.
Default Request Reply Pattern which simply creates the selector according to the request reply pattern
Custom Exception thrown when the extension was not able to create a given Destination
Type identifier for a Destination.
 
 
 
Decorates the JMS ConnectionFactory in order to ensure JMS session instances are reused.
Declares the kind of Acknowledgement mode supported.
Jms102bSupport is a template class to provide an abstraction to to the Jms 1.0.2b api specification.
Jms11Support is a template class to provide an abstraction to to the JMS 1.1 API specification.
 
 
Errors that can be thrown in the acknowledge operation.
ModuleException to be thrown in the cases in which acking a message fails
Interface to be implemented in enums representing Acknowledgement modes and give their representation in the InternalAckMode
Operation that allows the user to perform an ACK over a Message produced by the current JmsSession
 
Decorates the JMS ConnectionFactory in order to ensure JMS session instances are reused.
Utility class to reuse logic for JMS Extension
 
A Connection for the JmsConnector
Let each JmsListener specific implementation resolve which exception raised by the custom client (from now on, the client) is considered as a connection exception, which might lead to reconnection logic execution.
 
Operation that allows the user to consume a single Message from a given Destination
Errors that can be thrown in the JmsConsume#consume(DefaultJmsConfig, JmsTransactionalConnection, String, ConsumerType, ConsumerAckMode, String, String, String, Long, TimeUnit) operation operation.
ModuleException to be thrown in the cases in which the received content to be written is invalid.
 
 
 
Errors for the JMS extension
ExceptionHandler for the JMS extension.
Custom generic exception for JmsConnector thrown errors
JMS header fields contain values used by both clients and providers to identify and route messages.
 
Builder Pattern Template for JmsHeaders
ModuleException to be thrown in the cases in which a message body invalid or cannot be converted to a supported type
JMS Subscriber for Destinations, allows to listen for incoming Messages
 
Custom lock implementation to be used in JmsListener to give the capability to the message listener work synchronously consuming and processing messages through the entire flow.
Factory for instances of JmsListenerLock
 
 
Wrapper implementation of a JMS MessageConsumer
Common utility which encapsulates the logic of dispatching a received message to a flow.
 
MessageListener for the JmsListener to subscribe to a TOPIC or QUEUE receives Message and dispatch those messages through the flow.
MessageConsumerDelegate implementation which uses MessageListener
Factory pattern implementation in charge of creating instances of JmsMessageListener
Wrapper implementation of a JMS MessageProducer
Container element for all the properties present in a JMS Message.
JmsMessageUtils contains helper method for dealing with JMS messages in Mule.
Exception which is thrown when a required library was not found.
Base implementation of a PoolingConnectionProvider for JmsConnections
An OutputTypeResolver for JMS operations
Configuration parameters for sending messages to a JMS Queue or Topic
Operation that allows the user to send a message to a JMS Destination
Operation that allows the user to send a message to a JMS Destination and waits for a response either to the provided ReplyTo destination or to a temporary Destination created dynamically
Errors that can be thrown in the JmsPublishConsume#publishConsume(DefaultJmsConfig, JmsConnection, String, JmsMessageBuilder, JmsPublishParameters, JmsConsumeParameters) operation operation.
CompletionListener for the publish operation
 
Errors that can be thrown in the JmsPublish#publish(DefaultJmsConfig, JmsTransactionalConnection, String, DestinationType, JmsMessageBuilder, JmsPublishParameters) operation operation.
JmsExtensionException to be thrown in the cases where an error occurs when trying to publish a message
Contains the parameters that can override the default values for publishing a Message
The JmsReconnectionManager is responsible for managing and orchestrating the different steps in the reconnection process.
A provider of a reconnection manager for each configuration.
Cleaner that releases and cleans broker-specific Connection connection object resources.
Enables the creation of an outgoing Message along with the response configuration.
Factory class for creating an Operation Result based on a JMS Message
JmsExtensionException to be thrown in the case that an Security related error occurs.
Wrapper element for a JMS Session that relates the session with its AckID
Manager that takes the responsibility of register the session information to be able to execute a manual acknowledgement or a recover over a Session.
Errors that can be thrown in the JmsAcknowledge#recoverSession(String) operation.
ModuleException to be thrown in the cases in which recovering a session fails
Versions of the JMS Spec supported by the JmsConnector
JmsSupport is an interface that provides a polymorphic facade to the JMS 1.0.2b, 1.1 and 2.0 API specifications.
 
ModuleException that represents an error when consuming a Message but a timeout is reached before the Message arrives
Implementation of the JmsConnection which implements TransactionalConnection for Transaction Support in the JmsConnector
Base implementation of a PoolingConnectionProvider for JmsConnections
Wrapper for an XAResource which makes it compatible with XA Transactions in Mule 4.
Jms Message consumer which polls a destination inside a XA Transaction.
MessageConsumerDelegate implementation which consumes messages inside XA Transactions doing polling.
Declaration of the predefined names for JMSX properties, according to JMS spec.
JMS reserves the 'JMSX' property name prefix for JMS defined properties.
Builder that provides a simple way of creating a JmsxProperties instance based on the predefined properties names.
A ConnectionFactory that wraps a delegate that is discovered using a JndiNameResolver
Defines a strategy for lookup objects by name using JNDI.
Declares the properties required to create a JndiNameResolver
Provides a JndiNameResolver or the set of properties required to create one, represented by JndiNameResolverProperties
Defines the behaviours that are supported when looking for a destination based on its name while using a JNDI name resolver.
Strategy interface for different implementations of a JMS Message Consumer
JmsMessageConsumer factory pattern implementation.
Container used to describe a MessageConsumer and its related resources.
Implementation of CachingConfiguration that disables session caching This CachingConfiguration is the recommended only if an external CachingConnectionFactory is already being parameterized or if this extension is being used in the context of a Java EE web or EJB application.
Null pattern implementation for JmsListenerLock which doesn't lock the listener waiting for the message processing.
Closes the producer resources scheduling a task
 
Declares the parameters that can override the default values for publishing a Message
Implementation of ConsumerType that marks the consumed Destination as a Queue.
Enum which list the available Request Reply Patterns supported by the JMS Client
 
Defines a simple JndiNameResolver that maintains a Context instance opened all the time and always relies on the context to do the look ups.
Group of parameters of the configuration of a Message Source
Implementation of ConsumerType that marks the consumed Destination as a Topic and provides a way to configure topic-specific consumer parameters
Enum to indicate the current status of a transaction over a session.
JMS connection created when using a ConnectionFactory with XA enabled.
Configuration for an XA pool