Class ActiveMQXASslConnectionFactory

java.lang.Object

org.apache.activemq.jndi.JNDIBaseStorable

org.apache.activemq.ActiveMQConnectionFactory

org.apache.activemq.ActiveMQSslConnectionFactory

org.apache.activemq.ActiveMQXASslConnectionFactory

All Implemented Interfaces:

jakarta.jms.ConnectionFactory, jakarta.jms.QueueConnectionFactory, jakarta.jms.TopicConnectionFactory, jakarta.jms.XAConnectionFactory, jakarta.jms.XAQueueConnectionFactory, jakarta.jms.XATopicConnectionFactory, Externalizable, Serializable, Cloneable, Referenceable, JNDIStorableInterface, StatsCapable

public class ActiveMQXASslConnectionFactory
extends ActiveMQSslConnectionFactory
implements jakarta.jms.XAConnectionFactory, jakarta.jms.XAQueueConnectionFactory, jakarta.jms.XATopicConnectionFactory

See Also:

• Serialized Form

Field Summary

Fields inherited from class ActiveMQSslConnectionFactory

keyManager, keyStore, keyStoreKeyPassword, keyStorePassword, keyStoreType, secureRandom, trustManager, trustStore, trustStorePassword, trustStoreType

Fields inherited from class ActiveMQConnectionFactory

alwaysSessionAsync, brokerURL, clientID, DEFAULT_BROKER_BIND_URL, DEFAULT_BROKER_URL, DEFAULT_MAX_INFLATED_DATA_SIZE_RATIO, DEFAULT_PASSWORD, DEFAULT_PRODUCER_WINDOW_SIZE, DEFAULT_USER, dispatchAsync, password, userName, xaAckMode

Constructor Summary

Constructors

Constructor	Description
ActiveMQXASslConnectionFactory()
ActiveMQXASslConnectionFactory(String brokerURL)
ActiveMQXASslConnectionFactory(URI brokerURL)

Method Summary

Modifier and Type	Method	Description
protected ActiveMQConnection	createActiveMQConnection(Transport transport, JMSStatsImpl stats)
jakarta.jms.XAConnection	createXAConnection()
jakarta.jms.XAConnection	createXAConnection(String userName, String password)
jakarta.jms.XAJMSContext	createXAContext()
jakarta.jms.XAJMSContext	createXAContext(String userName, String password)
jakarta.jms.XAQueueConnection	createXAQueueConnection()
jakarta.jms.XAQueueConnection	createXAQueueConnection(String userName, String password)
jakarta.jms.XATopicConnection	createXATopicConnection()
jakarta.jms.XATopicConnection	createXATopicConnection(String userName, String password)
int	getXaAckMode()
void	populateProperties(Properties props)	Initialize the instance from properties stored in JNDI
void	setXaAckMode(int xaAckMode)

Methods inherited from class ActiveMQSslConnectionFactory

createKeyManager, createTransport, createTrustManager, getInputStream, getKeyStore, getKeyStoreKeyPassword, getKeyStorePassword, getKeyStoreType, getTrustStore, getTrustStorePassword, getTrustStoreType, loadClientCredential, setKeyAndTrustManagers, setKeyStore, setKeyStoreKeyPassword, setKeyStorePassword, setKeyStoreType, setTrustStore, setTrustStorePassword, setTrustStoreType

Methods inherited from class ActiveMQConnectionFactory

buildFromMap, buildFromProperties, configureConnection, copy, createActiveMQConnection, createActiveMQConnection, createConnection, createConnection, createContext, createContext, createContext, createContext, createQueueConnection, createQueueConnection, createTopicConnection, createTopicConnection, getAuditDepth, getAuditMaximumProducerNumber, getBlobTransferPolicy, getBrokerURL, getClientID, getClientIdGenerator, getClientIDPrefix, getClientInternalExceptionListener, getCloseTimeout, getConnectionIdGenerator, getConnectResponseTimeout, getConsumerFailoverRedeliveryWaitPeriod, getExceptionListener, getMaxInflatedDataSizeRatio, getMaxThreadPoolSize, getOptimizeAcknowledgeTimeOut, getOptimizedAckScheduledAckInterval, getPassword, getPrefetchPolicy, getProducerWindowSize, getRedeliveryPolicy, getRedeliveryPolicyMap, getRejectedTaskHandler, getRequestTimeout, getSendTimeout, getSessionTaskRunner, getStats, getTransformer, getTransportListener, getTrustedPackages, getUserName, getWarnAboutUnstartedConnectionTimeout, isAlwaysSessionAsync, isAlwaysSyncSend, isCheckForDuplicates, isConsumerExpiryCheckEnabled, isCopyMessageOnSend, isDisableTimeStampsByDefault, isDispatchAsync, isExclusiveConsumer, isMessagePrioritySupported, isNestedMapAndListEnabled, isNonBlockingRedelivery, isObjectMessageSerializationDefered, isOptimizeAcknowledge, isOptimizedMessageDispatch, isRmIdFromConnectionId, isSendAcksAsync, isStatsEnabled, isStrictCompliance, isTransactedIndividualAck, isTrustAllPackages, isUseAsyncSend, isUseCompression, isUseDedicatedTaskRunner, isUseRetroactiveConsumer, isUseVirtualThreadTaskRunner, isWatchTopicAdvisories, setAlwaysSessionAsync, setAlwaysSyncSend, setAuditDepth, setAuditMaximumProducerNumber, setBlobTransferPolicy, setBrokerURL, setCheckForDuplicates, setClientID, setClientIdGenerator, setClientIDPrefix, setClientInternalExceptionListener, setCloseTimeout, setConnectionIdGenerator, setConnectionIDPrefix, setConnectResponseTimeout, setConsumerExpiryCheckEnabled, setConsumerFailoverRedeliveryWaitPeriod, setCopyMessageOnSend, setDisableTimeStampsByDefault, setDispatchAsync, setExceptionListener, setExclusiveConsumer, setMaxInflatedDataSizeRatio, setMaxThreadPoolSize, setMessagePrioritySupported, setNestedMapAndListEnabled, setNonBlockingRedelivery, setObjectMessageSerializationDefered, setOptimizeAcknowledge, setOptimizeAcknowledgeTimeOut, setOptimizedAckScheduledAckInterval, setOptimizedMessageDispatch, setPassword, setPrefetchPolicy, setProducerWindowSize, setRedeliveryPolicy, setRedeliveryPolicyMap, setRejectedTaskHandler, setRequestTimeout, setRmIdFromConnectionId, setSendAcksAsync, setSendTimeout, setSessionTaskRunner, setStatsEnabled, setStrictCompliance, setTransactedIndividualAck, setTransformer, setTransportListener, setTrustAllPackages, setTrustedPackages, setUseAsyncSend, setUseCompression, setUseDedicatedTaskRunner, setUseRetroactiveConsumer, setUserName, setUseVirtualThreadTaskRunner, setWarnAboutUnstartedConnectionTimeout, setWatchTopicAdvisories

Methods inherited from class JNDIBaseStorable

getProperties, getReference, readExternal, setProperties, writeExternal

Methods inherited from class Object

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

Methods inherited from interface jakarta.jms.ConnectionFactory

createConnection, createConnection, createContext, createContext, createContext, createContext

Methods inherited from interface jakarta.jms.QueueConnectionFactory

createQueueConnection, createQueueConnection

Methods inherited from interface jakarta.jms.TopicConnectionFactory

createTopicConnection, createTopicConnection

Constructor Details

ActiveMQXASslConnectionFactory

public ActiveMQXASslConnectionFactory()

ActiveMQXASslConnectionFactory

public ActiveMQXASslConnectionFactory(String brokerURL)

ActiveMQXASslConnectionFactory

public ActiveMQXASslConnectionFactory(URI brokerURL)

Method Details

createXAConnection

public jakarta.jms.XAConnection createXAConnection()
                                            throws jakarta.jms.JMSException

Specified by:

createXAConnection in interface jakarta.jms.XAConnectionFactory

Throws:

jakarta.jms.JMSException

createXAConnection

public jakarta.jms.XAConnection createXAConnection(String userName,
 String password)
                                            throws jakarta.jms.JMSException

Specified by:

createXAConnection in interface jakarta.jms.XAConnectionFactory

Throws:

jakarta.jms.JMSException

createXAQueueConnection

public jakarta.jms.XAQueueConnection createXAQueueConnection()
                                                      throws jakarta.jms.JMSException

Specified by:

createXAQueueConnection in interface jakarta.jms.XAQueueConnectionFactory

Throws:

jakarta.jms.JMSException

createXAQueueConnection

public jakarta.jms.XAQueueConnection createXAQueueConnection(String userName,
 String password)
                                                      throws jakarta.jms.JMSException

Specified by:

createXAQueueConnection in interface jakarta.jms.XAQueueConnectionFactory

Throws:

jakarta.jms.JMSException

createXATopicConnection

public jakarta.jms.XATopicConnection createXATopicConnection()
                                                      throws jakarta.jms.JMSException

Specified by:

createXATopicConnection in interface jakarta.jms.XATopicConnectionFactory

Throws:

jakarta.jms.JMSException

createXATopicConnection

public jakarta.jms.XATopicConnection createXATopicConnection(String userName,
 String password)
                                                      throws jakarta.jms.JMSException

Specified by:

createXATopicConnection in interface jakarta.jms.XATopicConnectionFactory

Throws:

jakarta.jms.JMSException

createXAContext

public jakarta.jms.XAJMSContext createXAContext()

Specified by:

createXAContext in interface jakarta.jms.XAConnectionFactory

createXAContext

public jakarta.jms.XAJMSContext createXAContext(String userName,
 String password)

Specified by:

createXAContext in interface jakarta.jms.XAConnectionFactory

createActiveMQConnection

protected ActiveMQConnection createActiveMQConnection(Transport transport,
 JMSStatsImpl stats)
                                               throws Exception

Overrides:

createActiveMQConnection in class ActiveMQConnectionFactory

Throws:

Exception

getXaAckMode

public int getXaAckMode()

setXaAckMode

public void setXaAckMode(int xaAckMode)

populateProperties

public void populateProperties(Properties props)

Description copied from class: JNDIBaseStorable

Initialize the instance from properties stored in JNDI

Overrides:

populateProperties in class ActiveMQConnectionFactory

Parameters:

props -