public class HornetQResourceAdapter extends Object implements javax.resource.spi.ResourceAdapter, Serializable
Constructor and Description |
---|
HornetQResourceAdapter()
Constructor
|
Modifier and Type | Method and Description |
---|---|
HornetQConnectionFactory |
createHornetQConnectionFactory(ConnectionFactoryProperties overrideProperties) |
HornetQConnectionFactory |
createRecoveryHornetQConnectionFactory(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,HornetQActivation> |
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
|
String |
getConnectionLoadBalancingPolicyClassName() |
String |
getConnectionParameters() |
Long |
getConnectionTTL()
Get connection TTL
|
String |
getConnectorClassName() |
Integer |
getConsumerMaxRate()
Get consumer max rate
|
Integer |
getConsumerWindowSize()
Get consumer window size
|
HornetQConnectionFactory |
getDefaultHornetQConnectionFactory() |
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 |
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 |
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 HornetQRAProperties |
getProperties()
Get the resource adapter properties
|
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
|
String |
getTransactionManagerLocatorClass() |
String |
getTransactionManagerLocatorMethod() |
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() |
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 |
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 |
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(HornetQRAManagedConnectionFactory hornetQRAManagedConnectionFactory) |
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 |
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
|
void |
setTransactionManagerLocatorClass(String transactionManagerLocatorClass) |
void |
setTransactionManagerLocatorMethod(String transactionManagerLocatorMethod) |
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 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 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 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 HornetQRAProperties getProperties()
protected void setup() throws HornetQException
HornetQException
public Map<javax.resource.spi.ActivationSpec,HornetQActivation> getActivations()
public HornetQConnectionFactory getDefaultHornetQConnectionFactory() throws javax.resource.ResourceException
javax.resource.ResourceException
public void setTransactionManagerLocatorClass(String transactionManagerLocatorClass)
transactionManagerLocatorClass
- HornetQRAProperties.setTransactionManagerLocatorClass(java.lang.String)
public String getTransactionManagerLocatorClass()
HornetQRAProperties.getTransactionManagerLocatorClass()
public String getJgroupsChannelLocatorClass()
HornetQRAProperties.getJgroupsChannelLocatorClass()
public void setJgroupsChannelLocatorClass(String jgroupsChannelLocatorClass)
org.hornetq.ra.HornetQRAProperties#setJgroupsChannelLocatorClass()
public String getJgroupsChannelRefName()
HornetQRAProperties.getJgroupsChannelRefName()
public void setJgroupsChannelRefName(String jgroupsChannelRefName)
org.hornetq.ra.HornetQRAProperties#setJgroupsChannelRefName()
public String getTransactionManagerLocatorMethod()
HornetQRAProperties.getTransactionManagerLocatorMethod()
public void setTransactionManagerLocatorMethod(String transactionManagerLocatorMethod)
transactionManagerLocatorMethod
- HornetQRAProperties.setTransactionManagerLocatorMethod(java.lang.String)
public HornetQConnectionFactory createHornetQConnectionFactory(ConnectionFactoryProperties overrideProperties)
public HornetQConnectionFactory createRecoveryHornetQConnectionFactory(ConnectionFactoryProperties overrideProperties)
public Map<String,Object> overrideConnectionParameters(Map<String,Object> connectionParams, Map<String,Object> overrideConnectionParams)
public void setManagedConnectionFactory(HornetQRAManagedConnectionFactory hornetQRAManagedConnectionFactory)
public SensitiveDataCodec<String> getCodecInstance()
Copyright © 2017 JBoss, a division of Red Hat. All Rights Reserved.