Package org.mule.jms.commons.internal.connection.provider

Class JmsXaConnectionProvider

java.lang.Object

org.mule.jms.commons.internal.connection.provider.AbstractJmsConnectionProvider

org.mule.jms.commons.internal.connection.provider.JmsXaConnectionProvider

All Implemented Interfaces:

org.mule.runtime.api.lifecycle.Disposable, org.mule.runtime.api.lifecycle.Initialisable, org.mule.sdk.api.connectivity.ConnectionProvider<JmsTransactionalConnection>, org.mule.sdk.api.connectivity.XATransactionalConnectionProvider<JmsTransactionalConnection>

public class JmsXaConnectionProvider
extends AbstractJmsConnectionProvider
implements org.mule.sdk.api.connectivity.XATransactionalConnectionProvider<JmsTransactionalConnection>

Base implementation of a PoolingConnectionProvider for JmsConnections

Since:

1.0

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	JmsXaConnectionProvider.Builder	Builder for JmsXaConnectionProvider.

Field Summary

Fields inherited from class org.mule.jms.commons.internal.connection.provider.AbstractJmsConnectionProvider

cachingStrategy, configName, connectionFactorySupplier, connectionParameters, disconnecting, exceptionListener, isCacheEnabled, isIBM, isXa, jmsConnectionFactory, jmsSessionManager, jmsSupport, jmsSupportFactory, lastValidationException, LOGGER, reconnectionManager, setupSsl, specification, VALIDATION_THREAD_NAME_PATTERN, VALIDATION_TIMEOUT, xaPoolParameters

Fields inherited from interface org.mule.runtime.api.lifecycle.Disposable

PHASE_NAME

Fields inherited from interface org.mule.runtime.api.lifecycle.Initialisable

PHASE_NAME

Method Summary

Modifier and Type	Method	Description
static JmsXaConnectionProvider.Builder	builder()	Creates a new Builder for JmsXaConnectionProvider.
JmsTransactionalConnection	connect()
void	disconnect(JmsTransactionalConnection jmsConnection)
org.mule.runtime.api.config.PoolingProfile	getXaPoolingProfile()	Creates a PoolingProfile for XA connections using the existing XaPoolParameters.
void	initialise()
org.mule.sdk.api.connectivity.ConnectionValidationResult	validate(JmsTransactionalConnection jmsConnection)

Methods inherited from class org.mule.jms.commons.internal.connection.provider.AbstractJmsConnectionProvider

createConnection, createJmsSupport, dispose, doClose, doDisconnect, doStop, doValidate, getConnectionFactory, getConnectionParameters, getJmsSupport, getSpecification, handleConnectionError, validateWithTimeout

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

builder

public static JmsXaConnectionProvider.Builder builder()

Creates a new Builder for JmsXaConnectionProvider.

Returns:

a new Builder instance

initialise

public void initialise()
                throws org.mule.runtime.api.lifecycle.InitialisationException

Specified by:

initialise in interface org.mule.runtime.api.lifecycle.Initialisable

Throws:

org.mule.runtime.api.lifecycle.InitialisationException

connect

public JmsTransactionalConnection connect()
                                   throws org.mule.runtime.api.connection.ConnectionException

Specified by:

connect in interface org.mule.sdk.api.connectivity.ConnectionProvider<JmsTransactionalConnection>

Throws:

org.mule.runtime.api.connection.ConnectionException

validate

public org.mule.sdk.api.connectivity.ConnectionValidationResult validate(JmsTransactionalConnection jmsConnection)

Specified by:

validate in interface org.mule.sdk.api.connectivity.ConnectionProvider<JmsTransactionalConnection>

disconnect

public void disconnect(JmsTransactionalConnection jmsConnection)

Specified by:

disconnect in interface org.mule.sdk.api.connectivity.ConnectionProvider<JmsTransactionalConnection>

getXaPoolingProfile

public org.mule.runtime.api.config.PoolingProfile getXaPoolingProfile()

Creates a PoolingProfile for XA connections using the existing XaPoolParameters. The new Mule Runtime will handle XA connections automatically when an XA connection is returned. The connector just needs to retrieve the connection from the underlying driver.

Specified by:

getXaPoolingProfile in interface org.mule.sdk.api.connectivity.XATransactionalConnectionProvider<JmsTransactionalConnection>

Returns:

PoolingProfile for XA connections, or null if not available