Package org.wildfly.extension.messaging.activemq

Class ActiveMQResourceAdapter

java.lang.Object

org.apache.activemq.artemis.ra.ActiveMQResourceAdapter

org.wildfly.extension.messaging.activemq.ActiveMQResourceAdapter

All Implemented Interfaces:

ResourceAdapter, Serializable

public class ActiveMQResourceAdapter
extends ActiveMQResourceAdapter

Custom resource adapter that returns an appropriate BroadcastEndpointFactory if discovery is configured using JGroups.

Author:

Paul Ferraro

See Also:

• Serialized Form

Field Summary

Fields inherited from class org.apache.activemq.artemis.ra.ActiveMQResourceAdapter

PRODUCT_NAME

Constructor Summary

Constructors

Constructor	Description
ActiveMQResourceAdapter()

Method Summary

Modifier and Type	Method	Description
protected BroadcastEndpointFactory	createBroadcastEndpointFactory(ConnectionFactoryProperties overrideProperties)
ActiveMQConnectionFactory	createRecoveryActiveMQConnectionFactory(ConnectionFactoryProperties overrideProperties)	Workaround for WFLY-18756 until https://issues.apache.org/jira/browse/ARTEMIS-4508 is merged and released.
WorkManager	getWorkManager()

Methods inherited from class org.apache.activemq.artemis.ra.ActiveMQResourceAdapter

closeConnectionFactory, createSession, endpointActivation, endpointDeactivation, equals, getActivations, getAutoGroup, getBlockOnAcknowledge, getBlockOnDurableSend, getBlockOnNonDurableSend, getCallFailoverTimeout, getCallTimeout, getClientFailureCheckPeriod, getClientID, getCodec, getCompressionLevel, getConfirmationWindowSize, getConnectionFactory, getConnectionLoadBalancingPolicyClassName, getConnectionParameters, getConnectionTTL, getConnectorClassName, getConsumerMaxRate, getConsumerWindowSize, getDefaultActiveMQConnectionFactory, getDeserializationAllowList, getDeserializationBlackList, getDeserializationDenyList, getDeserializationWhiteList, getDiscoveryAddress, getDiscoveryInitialWaitTimeout, getDiscoveryLocalBindAddress, getDiscoveryPort, getDiscoveryRefreshTimeout, getDupsOKBatchSize, getEntries, getGroupID, getHA, getInitialConnectAttempts, getInitialMessagePacketSize, getJgroupsChannelLocatorClass, getJgroupsChannelName, getJgroupsChannelRefName, getJgroupsFile, getJndiName, getJndiParams, getMaxRetryInterval, getMinLargeMessageSize, getParsedJndiParams, getPassword, getPasswordCodec, getPreAcknowledge, getProducerMaxRate, getProducerWindowSize, getProperties, getProtocolManagerFactoryStr, getReconnectAttempts, getRecoveryManager, getRetryInterval, getRetryIntervalMultiplier, getScheduledThreadPoolMaxSize, getSetupAttempts, getSetupInterval, getThreadPoolMaxSize, getTransactionBatchSize, getTSR, getUseGlobalPools, getUseLocalTx, getUserName, getUseTopologyForLoadBalancing, getXAResources, hashCode, isCacheDestinations, isCacheLargeMessagesClient, isCompressLargeMessage, isEnable1xPrefixes, isFailoverOnInitialConnection, isIgnoreJTA, isUseAutoRecovery, isUseJNDI, isUseMaskedPassword, isUseTopologyForLoadBalancing, newConnectionFactory, overrideConnectionParameters, setAutoGroup, setBlockOnAcknowledge, setBlockOnDurableSend, setBlockOnNonDurableSend, setCacheDestinations, setCacheLargeMessagesClient, setCallFailoverTimeout, setCallTimeout, setClientFailureCheckPeriod, setClientID, setCompressionLevel, setCompressLargeMessage, setConfirmationWindowSize, setConnectionLoadBalancingPolicyClassName, setConnectionParameters, setConnectionTTL, setConnectorClassName, setConsumerMaxRate, setConsumerWindowSize, setDeserializationAllowList, setDeserializationBlackList, setDeserializationDenyList, setDeserializationWhiteList, setDiscoveryAddress, setDiscoveryInitialWaitTimeout, setDiscoveryLocalBindAddress, setDiscoveryPort, setDiscoveryRefreshTimeout, setDupsOKBatchSize, setEnable1xPrefixes, setEntries, setFailoverOnInitialConnection, setGroupID, setHA, setIgnoreJTA, setInitialConnectAttempts, setInitialMessagePacketSize, setJgroupsChannelLocatorClass, setJgroupsChannelName, setJgroupsChannelRefName, setJgroupsFile, setJndiParams, setManagedConnectionFactory, setMaxRetryInterval, setMinLargeMessageSize, setPassword, setPasswordCodec, setPreAcknowledge, setProducerMaxRate, setProducerWindowSize, setProtocolManagerFactoryStr, setReconnectAttempts, setRetryInterval, setRetryIntervalMultiplier, setScheduledThreadPoolMaxSize, setSetupAttempts, setSetupInterval, setThreadPoolMaxSize, setTransactionBatchSize, setup, setUseAutoRecovery, setUseGlobalPools, setUseJNDI, setUseLocalTx, setUseMaskedPassword, setUserName, setUseTopologyForLoadBalancing, start, stop

Methods inherited from class java.lang.Object

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

Constructor Details

ActiveMQResourceAdapter

public ActiveMQResourceAdapter()

Method Details

createBroadcastEndpointFactory

protected BroadcastEndpointFactory createBroadcastEndpointFactory(ConnectionFactoryProperties overrideProperties)

Overrides:

createBroadcastEndpointFactory in class ActiveMQResourceAdapter

createRecoveryActiveMQConnectionFactory

public ActiveMQConnectionFactory createRecoveryActiveMQConnectionFactory(ConnectionFactoryProperties overrideProperties)

Workaround for WFLY-18756 until https://issues.apache.org/jira/browse/ARTEMIS-4508 is merged and released.

Overrides:

createRecoveryActiveMQConnectionFactory in class ActiveMQResourceAdapter

getWorkManager

public WorkManager getWorkManager()

Overrides:

getWorkManager in class ActiveMQResourceAdapter