public class ActiveMQResourceAdapter extends Object implements javax.resource.spi.ResourceAdapter, Serializable
Modifier and Type | Field and Description |
---|---|
static String |
PRODUCT_NAME
The Name of the product that this resource adapter represents.
|
Constructor and Description |
---|
ActiveMQResourceAdapter()
Constructor
|
Modifier and Type | Method and Description |
---|---|
void |
closeConnectionFactory(ConnectionFactoryProperties properties) |
ActiveMQConnectionFactory |
createRecoveryActiveMQConnectionFactory(ConnectionFactoryProperties overrideProperties) |
ClientSession |
createSession(ClientSessionFactory parameterFactory,
int ackMode,
String user,
String pass,
Boolean preAck,
Integer dupsOkBatchSize,
Integer transactionBatchSize,
boolean deliveryTransacted,
boolean useLocalTx,
Integer txTimeout) |
void |
endpointActivation(javax.resource.spi.endpoint.MessageEndpointFactory endpointFactory,
javax.resource.spi.ActivationSpec spec)
Endpoint activation
|
void |
endpointDeactivation(javax.resource.spi.endpoint.MessageEndpointFactory endpointFactory,
javax.resource.spi.ActivationSpec spec)
Endpoint deactivation
|
boolean |
equals(Object obj)
Indicates whether some other object is "equal to" this one.
|
Map<javax.resource.spi.ActivationSpec,ActiveMQActivation> |
getActivations() |
Boolean |
getAutoGroup()
Get auto group
|
Boolean |
getBlockOnAcknowledge()
Get block on acknowledge
|
Boolean |
getBlockOnDurableSend()
Get block on durable send
|
Boolean |
getBlockOnNonDurableSend()
Get block on non durable send
|
Long |
getCallFailoverTimeout()
Get call failover timeout
|
Long |
getCallTimeout()
Get call timeout
|
Long |
getClientFailureCheckPeriod()
Get client failure check period
|
String |
getClientID()
Get the client ID
|
SensitiveDataCodec<String> |
getCodecInstance() |
Integer |
getConfirmationWindowSize()
Get confirmation window size
|
ActiveMQConnectionFactory |
getConnectionFactory(ConnectionFactoryProperties overrideProperties) |
String |
getConnectionLoadBalancingPolicyClassName() |
String |
getConnectionParameters() |
Long |
getConnectionTTL()
Get connection TTL
|
String |
getConnectorClassName() |
Integer |
getConsumerMaxRate()
Get consumer max rate
|
Integer |
getConsumerWindowSize()
Get consumer window size
|
ActiveMQConnectionFactory |
getDefaultActiveMQConnectionFactory() |
String |
getDeserializationBlackList() |
String |
getDeserializationWhiteList() |
String |
getDiscoveryAddress()
Get the discovery group name
|
Long |
getDiscoveryInitialWaitTimeout()
Get discovery initial wait timeout
|
String |
getDiscoveryLocalBindAddress()
get the discovery local bind address
|
Integer |
getDiscoveryPort()
Get the discovery group port
|
Long |
getDiscoveryRefreshTimeout()
Get discovery refresh timeout
|
Integer |
getDupsOKBatchSize()
Get dups ok batch size
|
String |
getEntries() |
String |
getGroupID()
Get the group ID
|
Boolean |
getHA() |
Integer |
getInitialConnectAttempts()
Get number of initial connect attempts
|
Integer |
getInitialMessagePacketSize()
Get initial message packet size
|
String |
getJgroupsChannelLocatorClass() |
String |
getJgroupsChannelName() |
String |
getJgroupsChannelRefName() |
String |
getJgroupsFile() |
String |
getJndiName() |
String |
getJndiParams() |
Long |
getMaxRetryInterval()
Get maximum time for retry interval
|
Integer |
getMinLargeMessageSize()
Get min large message size
|
Hashtable<?,?> |
getParsedJndiParams() |
String |
getPassword()
Get the password
|
String |
getPasswordCodec() |
Boolean |
getPreAcknowledge()
Get pre acknowledge
|
Integer |
getProducerMaxRate()
Get producer max rate
|
Integer |
getProducerWindowSize()
Get producer window size
|
protected ActiveMQRAProperties |
getProperties()
Get the resource adapter properties
|
String |
getProtocolManagerFactoryStr() |
Integer |
getReconnectAttempts()
Get number of reconnect attempts
|
RecoveryManager |
getRecoveryManager() |
Long |
getRetryInterval()
Get retry interval
|
Double |
getRetryIntervalMultiplier()
Get retry interval multiplier
|
Integer |
getScheduledThreadPoolMaxSize() |
int |
getSetupAttempts() |
long |
getSetupInterval() |
Integer |
getThreadPoolMaxSize() |
TransactionManager |
getTM() |
Integer |
getTransactionBatchSize()
Get transaction batch size
|
Boolean |
getUseGlobalPools() |
Boolean |
getUseLocalTx()
Get the use XA flag
|
String |
getUserName()
Get the user name
|
javax.resource.spi.work.WorkManager |
getWorkManager()
Get the work manager
|
XAResource[] |
getXAResources(javax.resource.spi.ActivationSpec[] specs)
Get XA resources
|
int |
hashCode()
Return the hash code for the object
|
Boolean |
isCacheLargeMessagesClient()
Get cacheLargeMessagesClient
|
Boolean |
isCompressLargeMessage()
Get compressLargeMessage
|
Boolean |
isFailoverOnInitialConnection()
Get isFailoverOnInitialConnection
|
Boolean |
isUseAutoRecovery() |
boolean |
isUseJNDI() |
Boolean |
isUseMaskedPassword() |
ActiveMQConnectionFactory |
newConnectionFactory(ConnectionFactoryProperties overrideProperties) |
Map<String,Object> |
overrideConnectionParameters(Map<String,Object> connectionParams,
Map<String,Object> overrideConnectionParams) |
void |
setAutoGroup(Boolean autoGroup)
Set auto group
|
void |
setBlockOnAcknowledge(Boolean blockOnAcknowledge)
Set block on acknowledge
|
void |
setBlockOnDurableSend(Boolean blockOnDurableSend)
Set block on durable send
|
void |
setBlockOnNonDurableSend(Boolean blockOnNonDurableSend)
Set block on non durable send
|
void |
setCacheLargeMessagesClient(Boolean cacheLargeMessagesClient)
Set cacheLargeMessagesClient
|
void |
setCallFailoverTimeout(Long callFailoverTimeout)
Set call failover timeout
|
void |
setCallTimeout(Long callTimeout)
Set call timeout
|
void |
setClientFailureCheckPeriod(Long clientFailureCheckPeriod)
Set client failure check period
|
void |
setClientID(String clientID)
Set the client ID
|
void |
setCompressLargeMessage(Boolean compressLargeMessage)
Set compressLargeMessage
|
void |
setConfirmationWindowSize(Integer confirmationWindowSize)
Set confirmation window size
|
void |
setConnectionLoadBalancingPolicyClassName(String connectionLoadBalancingPolicyClassName) |
void |
setConnectionParameters(String config) |
void |
setConnectionTTL(Long connectionTTL)
Set connection TTL
|
void |
setConnectorClassName(String connectorClassName) |
void |
setConsumerMaxRate(Integer consumerMaxRate)
Set consumer max rate
|
void |
setConsumerWindowSize(Integer consumerWindowSize)
Set consumer window size
|
void |
setDeserializationBlackList(String deserializationBlackList) |
void |
setDeserializationWhiteList(String deserializationWhiteList) |
void |
setDiscoveryAddress(String dgn)
Set the discovery group name
|
void |
setDiscoveryInitialWaitTimeout(Long discoveryInitialWaitTimeout)
Set discovery initial wait timeout
|
void |
setDiscoveryLocalBindAddress(String discoveryLocalBindAddress)
set the discovery local bind address
|
void |
setDiscoveryPort(Integer dgp)
Set the discovery group port
|
void |
setDiscoveryRefreshTimeout(Long discoveryRefreshTimeout)
Set discovery refresh timeout
|
void |
setDupsOKBatchSize(Integer dupsOKBatchSize)
Set dups ok batch size
|
void |
setEntries(String entries) |
void |
setFailoverOnInitialConnection(Boolean failoverOnInitialConnection)
Set failoverOnInitialConnection
|
void |
setGroupID(String groupID)
Set the group ID
|
void |
setHA(Boolean ha) |
void |
setInitialConnectAttempts(Integer initialConnectAttempts)
Set number of initial connect attempts
|
void |
setInitialMessagePacketSize(Integer initialMessagePacketSize)
Set initial message packet size
|
void |
setJgroupsChannelLocatorClass(String jgroupsChannelLocatorClass) |
void |
setJgroupsChannelName(String jgroupsChannelName) |
void |
setJgroupsChannelRefName(String jgroupsChannelRefName) |
void |
setJgroupsFile(String jgroupsFile) |
void |
setJndiParams(String jndiParams) |
void |
setManagedConnectionFactory(ActiveMQRAManagedConnectionFactory activeMQRAManagedConnectionFactory) |
void |
setMaxRetryInterval(Long maxRetryInterval)
Set maximum time for retry interval
|
void |
setMinLargeMessageSize(Integer minLargeMessageSize)
Set min large message size
|
void |
setPassword(String password)
Set the password
|
void |
setPasswordCodec(String passwordCodec) |
void |
setPreAcknowledge(Boolean preAcknowledge)
Set pre acknowledge
|
void |
setProducerMaxRate(Integer producerMaxRate)
Set producer max rate
|
void |
setProducerWindowSize(Integer producerWindowSize)
Set producer window size
|
void |
setProtocolManagerFactoryStr(String protocolManagerFactoryStr) |
void |
setReconnectAttempts(Integer reconnectAttempts)
Set number of reconnect attempts
|
void |
setRetryInterval(Long retryInterval)
Set retry interval
|
void |
setRetryIntervalMultiplier(Double retryIntervalMultiplier)
Set retry interval multiplier
|
void |
setScheduledThreadPoolMaxSize(Integer scheduledThreadPoolMaxSize) |
void |
setSetupAttempts(Integer setupAttempts) |
void |
setSetupInterval(Long interval) |
void |
setThreadPoolMaxSize(Integer threadPoolMaxSize) |
void |
setTransactionBatchSize(Integer transactionBatchSize)
Set transaction batch size
|
protected void |
setup()
Setup the factory
|
void |
setUseAutoRecovery(Boolean useAutoRecovery) |
void |
setUseGlobalPools(Boolean useGlobalPools) |
void |
setUseJNDI(Boolean value) |
void |
setUseLocalTx(Boolean localTx)
Set the use XA flag
|
void |
setUseMaskedPassword(Boolean useMaskedPassword) |
void |
setUserName(String userName)
Set the user name
|
void |
start(javax.resource.spi.BootstrapContext ctx)
Start
|
void |
stop()
Stop
|
public static final String PRODUCT_NAME
public TransactionManager getTM()
public void endpointActivation(javax.resource.spi.endpoint.MessageEndpointFactory endpointFactory, javax.resource.spi.ActivationSpec spec) throws javax.resource.ResourceException
endpointActivation
in interface javax.resource.spi.ResourceAdapter
endpointFactory
- The endpoint factoryspec
- The activation specjavax.resource.ResourceException
- Thrown if an error occurspublic void endpointDeactivation(javax.resource.spi.endpoint.MessageEndpointFactory endpointFactory, javax.resource.spi.ActivationSpec spec)
endpointDeactivation
in interface javax.resource.spi.ResourceAdapter
endpointFactory
- The endpoint factoryspec
- The activation specpublic XAResource[] getXAResources(javax.resource.spi.ActivationSpec[] specs) throws javax.resource.ResourceException
getXAResources
in interface javax.resource.spi.ResourceAdapter
specs
- The activation specsjavax.resource.ResourceException
- Thrown if an error occurs or unsupportedpublic void start(javax.resource.spi.BootstrapContext ctx) throws javax.resource.spi.ResourceAdapterInternalException
start
in interface javax.resource.spi.ResourceAdapter
ctx
- The bootstrap contextjavax.resource.spi.ResourceAdapterInternalException
- Thrown if an error occurspublic void stop()
stop
in interface javax.resource.spi.ResourceAdapter
public void setUseAutoRecovery(Boolean useAutoRecovery)
public Boolean isUseAutoRecovery()
public Boolean isUseMaskedPassword()
public void setUseMaskedPassword(Boolean useMaskedPassword)
public void setPasswordCodec(String passwordCodec)
public String getPasswordCodec()
public void setConnectorClassName(String connectorClassName)
public String getConnectorClassName()
public String getConnectionParameters()
public void setConnectionParameters(String config)
public Boolean getHA()
public void setHA(Boolean ha)
public String getEntries()
public String getJndiName()
public void setEntries(String entries)
public String getDiscoveryAddress()
public void setJgroupsFile(String jgroupsFile)
public String getJgroupsFile()
public String getJgroupsChannelName()
public void setJgroupsChannelName(String jgroupsChannelName)
public void setDiscoveryAddress(String dgn)
dgn
- The valuepublic Integer getDiscoveryPort()
public void setDiscoveryLocalBindAddress(String discoveryLocalBindAddress)
discoveryLocalBindAddress
- the address valuepublic String getDiscoveryLocalBindAddress()
public void setDiscoveryPort(Integer dgp)
dgp
- The valuepublic Long getDiscoveryRefreshTimeout()
public void setDiscoveryRefreshTimeout(Long discoveryRefreshTimeout)
discoveryRefreshTimeout
- The valuepublic Long getDiscoveryInitialWaitTimeout()
public void setDiscoveryInitialWaitTimeout(Long discoveryInitialWaitTimeout)
discoveryInitialWaitTimeout
- The valuepublic Long getClientFailureCheckPeriod()
public void setClientFailureCheckPeriod(Long clientFailureCheckPeriod)
clientFailureCheckPeriod
- The valuepublic Long getConnectionTTL()
public void setConnectionTTL(Long connectionTTL)
connectionTTL
- The valuepublic Boolean isCacheLargeMessagesClient()
public void setCacheLargeMessagesClient(Boolean cacheLargeMessagesClient)
cacheLargeMessagesClient
- The valuepublic Boolean isCompressLargeMessage()
public void setFailoverOnInitialConnection(Boolean failoverOnInitialConnection)
failoverOnInitialConnection
- The valuepublic Boolean isFailoverOnInitialConnection()
public void setCompressLargeMessage(Boolean compressLargeMessage)
compressLargeMessage
- The valuepublic Long getCallTimeout()
public void setCallTimeout(Long callTimeout)
callTimeout
- The valuepublic Long getCallFailoverTimeout()
public void setCallFailoverTimeout(Long callFailoverTimeout)
callFailoverTimeout
- The valuepublic Integer getDupsOKBatchSize()
public void setDupsOKBatchSize(Integer dupsOKBatchSize)
dupsOKBatchSize
- The valuepublic Integer getTransactionBatchSize()
public void setTransactionBatchSize(Integer transactionBatchSize)
transactionBatchSize
- The valuepublic Integer getConsumerWindowSize()
public void setConsumerWindowSize(Integer consumerWindowSize)
consumerWindowSize
- The valuepublic Integer getConsumerMaxRate()
public void setConsumerMaxRate(Integer consumerMaxRate)
consumerMaxRate
- The valuepublic Integer getConfirmationWindowSize()
public void setConfirmationWindowSize(Integer confirmationWindowSize)
confirmationWindowSize
- The valuepublic Integer getProducerMaxRate()
public void setProducerMaxRate(Integer producerMaxRate)
producerMaxRate
- The valuepublic Integer getProducerWindowSize()
public void setProducerWindowSize(Integer producerWindowSize)
producerWindowSize
- The valuepublic String getProtocolManagerFactoryStr()
public void setProtocolManagerFactoryStr(String protocolManagerFactoryStr)
public String getDeserializationBlackList()
public void setDeserializationBlackList(String deserializationBlackList)
public String getDeserializationWhiteList()
public void setDeserializationWhiteList(String deserializationWhiteList)
public Integer getMinLargeMessageSize()
public void setMinLargeMessageSize(Integer minLargeMessageSize)
minLargeMessageSize
- The valuepublic Boolean getBlockOnAcknowledge()
public void setBlockOnAcknowledge(Boolean blockOnAcknowledge)
blockOnAcknowledge
- The valuepublic Boolean getBlockOnNonDurableSend()
public void setBlockOnNonDurableSend(Boolean blockOnNonDurableSend)
blockOnNonDurableSend
- The valuepublic Boolean getBlockOnDurableSend()
public void setBlockOnDurableSend(Boolean blockOnDurableSend)
blockOnDurableSend
- The valuepublic Boolean getAutoGroup()
public void setAutoGroup(Boolean autoGroup)
autoGroup
- The valuepublic Boolean getPreAcknowledge()
public void setPreAcknowledge(Boolean preAcknowledge)
preAcknowledge
- The valuepublic Integer getInitialConnectAttempts()
public void setInitialConnectAttempts(Integer initialConnectAttempts)
initialConnectAttempts
- The valuepublic Integer getInitialMessagePacketSize()
public void setInitialMessagePacketSize(Integer initialMessagePacketSize)
initialMessagePacketSize
- The valuepublic Long getRetryInterval()
public void setRetryInterval(Long retryInterval)
retryInterval
- The valuepublic Double getRetryIntervalMultiplier()
public void setRetryIntervalMultiplier(Double retryIntervalMultiplier)
retryIntervalMultiplier
- The valuepublic Long getMaxRetryInterval()
public void setMaxRetryInterval(Long maxRetryInterval)
maxRetryInterval
- The valuepublic Integer getReconnectAttempts()
public void setReconnectAttempts(Integer reconnectAttempts)
reconnectAttempts
- The valuepublic String getConnectionLoadBalancingPolicyClassName()
public void setConnectionLoadBalancingPolicyClassName(String connectionLoadBalancingPolicyClassName)
public Integer getScheduledThreadPoolMaxSize()
public void setScheduledThreadPoolMaxSize(Integer scheduledThreadPoolMaxSize)
public Integer getThreadPoolMaxSize()
public void setThreadPoolMaxSize(Integer threadPoolMaxSize)
public Boolean getUseGlobalPools()
public void setUseGlobalPools(Boolean useGlobalPools)
public String getUserName()
public void setUserName(String userName)
userName
- The valuepublic String getPassword()
public void setPassword(String password)
password
- The valuepublic boolean isUseJNDI()
public void setUseJNDI(Boolean value)
value
- the useJNDI to setpublic String getJndiParams()
public void setJndiParams(String jndiParams)
public Hashtable<?,?> getParsedJndiParams()
public String getClientID()
public void setClientID(String clientID)
clientID
- The client idpublic String getGroupID()
public void setGroupID(String groupID)
groupID
- The group idpublic Boolean getUseLocalTx()
public void setUseLocalTx(Boolean localTx)
localTx
- The valuepublic int getSetupAttempts()
public void setSetupAttempts(Integer setupAttempts)
public long getSetupInterval()
public void setSetupInterval(Long interval)
public boolean equals(Object obj)
public int hashCode()
public javax.resource.spi.work.WorkManager getWorkManager()
public ClientSession createSession(ClientSessionFactory parameterFactory, int ackMode, String user, String pass, Boolean preAck, Integer dupsOkBatchSize, Integer transactionBatchSize, boolean deliveryTransacted, boolean useLocalTx, Integer txTimeout) throws Exception
Exception
public RecoveryManager getRecoveryManager()
protected ActiveMQRAProperties getProperties()
protected void setup() throws ActiveMQException
ActiveMQException
public Map<javax.resource.spi.ActivationSpec,ActiveMQActivation> getActivations()
public ActiveMQConnectionFactory getDefaultActiveMQConnectionFactory() throws javax.resource.ResourceException
javax.resource.ResourceException
public String getJgroupsChannelLocatorClass()
public void setJgroupsChannelLocatorClass(String jgroupsChannelLocatorClass)
public String getJgroupsChannelRefName()
ActiveMQRAProperties.getJgroupsChannelRefName()
public void setJgroupsChannelRefName(String jgroupsChannelRefName)
public ActiveMQConnectionFactory getConnectionFactory(ConnectionFactoryProperties overrideProperties)
public ActiveMQConnectionFactory newConnectionFactory(ConnectionFactoryProperties overrideProperties)
public ActiveMQConnectionFactory createRecoveryActiveMQConnectionFactory(ConnectionFactoryProperties overrideProperties)
public Map<String,Object> overrideConnectionParameters(Map<String,Object> connectionParams, Map<String,Object> overrideConnectionParams)
public void setManagedConnectionFactory(ActiveMQRAManagedConnectionFactory activeMQRAManagedConnectionFactory)
public SensitiveDataCodec<String> getCodecInstance()
public void closeConnectionFactory(ConnectionFactoryProperties properties)
Copyright © 2016 The Apache Software Foundation. All rights reserved.