|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.jboss.messaging.ra.JBMResourceAdapter
public class JBMResourceAdapter
The resource adapter for JBoss Messaging
Constructor Summary | |
---|---|
JBMResourceAdapter()
Constructor |
Method Summary | |
---|---|
JBossConnectionFactory |
createJBossConnectionFactory(ConnectionFactoryProperties overrideProperties)
|
ClientSession |
createSession(ClientSessionFactory parameterFactory,
int ackMode,
java.lang.String user,
java.lang.String pass,
java.lang.Boolean preAck,
java.lang.Integer dupsOkBatchSize,
java.lang.Integer transactionBatchSize,
boolean deliveryTransacted,
boolean useLocalTx)
|
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(java.lang.Object obj)
Indicates whether some other object is "equal to" this one. |
java.lang.Boolean |
getAutoGroup()
Get auto group |
java.util.Map<java.lang.String,java.lang.Object> |
getBackupConnectionParameters()
|
java.lang.String |
getBackupConnectorClassName()
|
java.lang.Boolean |
getBlockOnAcknowledge()
Get block on acknowledge |
java.lang.Boolean |
getBlockOnNonPersistentSend()
Get block on non persistent send |
java.lang.Boolean |
getBlockOnPersistentSend()
Get block on persistent send |
java.lang.Long |
getCallTimeout()
Get call timeout |
java.lang.Long |
getClientFailureCheckPeriod()
Get client failure check period |
java.lang.String |
getClientID()
Get the client ID |
java.lang.String |
getConnectionLoadBalancingPolicyClassName()
|
java.util.Map<java.lang.String,java.lang.Object> |
getConnectionParameters()
|
java.lang.Long |
getConnectionTTL()
Get connection TTL |
java.lang.String |
getConnectorClassName()
|
java.lang.Integer |
getConsumerMaxRate()
Get consumer max rate |
java.lang.Integer |
getConsumerWindowSize()
Get consumer window size |
JBossConnectionFactory |
getDefaultJBossConnectionFactory()
|
java.lang.String |
getDiscoveryAddress()
Get the discovery group name |
java.lang.Long |
getDiscoveryInitialWaitTimeout()
Get discovery initial wait timeout |
java.lang.Integer |
getDiscoveryPort()
Get the discovery group port |
java.lang.Long |
getDiscoveryRefreshTimeout()
Get discovery refresh timeout |
java.lang.Integer |
getDupsOKBatchSize()
Get dups ok batch size |
java.lang.Boolean |
getFailoverOnServerShutdown()
Get failover on server shutdown |
java.lang.String |
getLoadBalancingPolicyClassName()
Get load balancing policy class name |
java.lang.Integer |
getMaxConnections()
Get max connections |
java.lang.Integer |
getMinLargeMessageSize()
Get min large message size |
java.lang.String |
getPassword()
Get the password |
java.lang.Boolean |
getPreAcknowledge()
Get pre acknowledge |
java.lang.Integer |
getProducerMaxRate()
Get producer max rate |
java.lang.Integer |
getProducerWindowSize()
Get producer window size |
protected JBMRAProperties |
getProperties()
Get the resource adapter properties |
java.lang.Integer |
getReconnectAttempts()
Get number of reconnect attempts |
java.lang.Long |
getRetryInterval()
Get retry interval |
java.lang.Double |
getRetryIntervalMultiplier()
Get retry interval multiplier |
java.lang.Integer |
getScheduledThreadPoolMaxSize()
|
java.lang.Integer |
getThreadPoolMaxSize()
|
java.lang.Integer |
getTransactionBatchSize()
Get transaction batch size |
java.lang.Boolean |
getUseGlobalPools()
|
java.lang.Boolean |
getUseLocalTx()
Get the use XA flag |
java.lang.String |
getUserName()
Get the user name |
java.lang.Boolean |
getUseXA()
Get the use XA flag |
javax.resource.spi.work.WorkManager |
getWorkManager()
Get the work manager |
javax.transaction.xa.XAResource[] |
getXAResources(javax.resource.spi.ActivationSpec[] specs)
Get XA resources |
int |
hashCode()
Return the hash code for the object |
java.lang.Boolean |
isFailoverOnServerShutdown()
Get failover on server shutdown |
void |
setAutoGroup(java.lang.Boolean autoGroup)
Set auto group |
void |
setBackupConnectorClassName(java.lang.String backupConnector)
|
void |
setBackupTransportConfiguration(java.lang.String config)
|
void |
setBlockOnAcknowledge(java.lang.Boolean blockOnAcknowledge)
Set block on acknowledge |
void |
setBlockOnNonPersistentSend(java.lang.Boolean blockOnNonPersistentSend)
Set block on non persistent send |
void |
setBlockOnPersistentSend(java.lang.Boolean blockOnPersistentSend)
Set block on persistent send |
void |
setCallTimeout(java.lang.Long callTimeout)
Set call timeout |
void |
setClientFailureCheckPeriod(java.lang.Long clientFailureCheckPeriod)
Set client failure check period |
void |
setClientID(java.lang.String clientID)
Set the client ID |
void |
setConnectionLoadBalancingPolicyClassName(java.lang.String connectionLoadBalancingPolicyClassName)
|
void |
setConnectionParameters(java.lang.String config)
|
void |
setConnectionTTL(java.lang.Long connectionTTL)
Set connection TTL |
void |
setConnectorClassName(java.lang.String connectorClassName)
|
void |
setConsumerMaxRate(java.lang.Integer consumerMaxRate)
Set consumer max rate |
void |
setConsumerWindowSize(java.lang.Integer consumerWindowSize)
Set consumer window size |
void |
setDiscoveryAddress(java.lang.String dgn)
Set the discovery group name |
void |
setDiscoveryInitialWaitTimeout(java.lang.Long discoveryInitialWaitTimeout)
Set discovery initial wait timeout |
void |
setDiscoveryPort(java.lang.Integer dgp)
Set the discovery group port |
void |
setDiscoveryRefreshTimeout(java.lang.Long discoveryRefreshTimeout)
Set discovery refresh timeout |
void |
setDupsOKBatchSize(java.lang.Integer dupsOKBatchSize)
Set dups ok batch size |
void |
setFailoverOnServerShutdown(java.lang.Boolean failoverOnServerShutdown)
Set failover on server shutdown |
void |
setLoadBalancingPolicyClassName(java.lang.String loadBalancingPolicyClassName)
Set load balancing policy class name |
void |
setMaxConnections(java.lang.Integer maxConnections)
Set max connections |
void |
setMinLargeMessageSize(java.lang.Integer minLargeMessageSize)
Set min large message size |
void |
setPassword(java.lang.String password)
Set the password |
void |
setPreAcknowledge(java.lang.Boolean preAcknowledge)
Set pre acknowledge |
void |
setProducerMaxRate(java.lang.Integer producerMaxRate)
Set producer max rate |
void |
setProducerWindowSize(java.lang.Integer producerWindowSize)
Set producer window size |
void |
setReconnectAttempts(java.lang.Integer reconnectAttempts)
Set number of reconnect attempts |
void |
setRetryInterval(java.lang.Long retryInterval)
Set retry interval |
void |
setRetryIntervalMultiplier(java.lang.Double retryIntervalMultiplier)
Set retry interval multiplier |
void |
setScheduledThreadPoolMaxSize(java.lang.Integer scheduledThreadPoolMaxSize)
|
void |
setThreadPoolMaxSize(java.lang.Integer threadPoolMaxSize)
|
void |
setTransactionBatchSize(java.lang.Integer transactionBatchSize)
Set transaction batch size |
protected void |
setup()
Setup the factory |
void |
setUseGlobalPools(java.lang.Boolean useGlobalPools)
|
void |
setUseLocalTx(java.lang.Boolean localTx)
Set the use XA flag |
void |
setUserName(java.lang.String userName)
Set the user name |
void |
setUseXA(java.lang.Boolean xa)
Set the use XA flag |
void |
start(javax.resource.spi.BootstrapContext ctx)
Start |
void |
stop()
Stop |
Methods inherited from class java.lang.Object |
---|
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public JBMResourceAdapter()
Method Detail |
---|
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 spec
javax.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 javax.transaction.xa.XAResource[] getXAResources(javax.resource.spi.ActivationSpec[] specs) throws javax.resource.ResourceException
getXAResources
in interface javax.resource.spi.ResourceAdapter
specs
- The activation specs
javax.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 context
javax.resource.spi.ResourceAdapterInternalException
- Thrown if an error occurspublic void stop()
stop
in interface javax.resource.spi.ResourceAdapter
public void setConnectorClassName(java.lang.String connectorClassName)
public java.lang.String getConnectorClassName()
public java.util.Map<java.lang.String,java.lang.Object> getConnectionParameters()
public void setConnectionParameters(java.lang.String config)
public java.lang.String getBackupConnectorClassName()
public void setBackupConnectorClassName(java.lang.String backupConnector)
public java.util.Map<java.lang.String,java.lang.Object> getBackupConnectionParameters()
public void setBackupTransportConfiguration(java.lang.String config)
public java.lang.String getDiscoveryAddress()
public void setDiscoveryAddress(java.lang.String dgn)
dgn
- The valuepublic java.lang.Integer getDiscoveryPort()
public void setDiscoveryPort(java.lang.Integer dgp)
dgp
- The valuepublic java.lang.Long getDiscoveryRefreshTimeout()
public void setDiscoveryRefreshTimeout(java.lang.Long discoveryRefreshTimeout)
discoveryRefreshTimeout
- The valuepublic java.lang.Long getDiscoveryInitialWaitTimeout()
public void setDiscoveryInitialWaitTimeout(java.lang.Long discoveryInitialWaitTimeout)
discoveryInitialWaitTimeout
- The valuepublic java.lang.String getLoadBalancingPolicyClassName()
public void setLoadBalancingPolicyClassName(java.lang.String loadBalancingPolicyClassName)
loadBalancingPolicyClassName
- The valuepublic java.lang.Long getClientFailureCheckPeriod()
public void setClientFailureCheckPeriod(java.lang.Long clientFailureCheckPeriod)
clientFailureCheckPeriod
- The valuepublic java.lang.Long getConnectionTTL()
public void setConnectionTTL(java.lang.Long connectionTTL)
connectionTTL
- The valuepublic java.lang.Long getCallTimeout()
public void setCallTimeout(java.lang.Long callTimeout)
callTimeout
- The valuepublic java.lang.Integer getDupsOKBatchSize()
public void setDupsOKBatchSize(java.lang.Integer dupsOKBatchSize)
dupsOKBatchSize
- The valuepublic java.lang.Integer getTransactionBatchSize()
public void setTransactionBatchSize(java.lang.Integer transactionBatchSize)
transactionBatchSize
- The valuepublic java.lang.Integer getConsumerWindowSize()
public void setConsumerWindowSize(java.lang.Integer consumerWindowSize)
consumerWindowSize
- The valuepublic java.lang.Integer getConsumerMaxRate()
public void setConsumerMaxRate(java.lang.Integer consumerMaxRate)
consumerMaxRate
- The valuepublic java.lang.Integer getProducerWindowSize()
public void setProducerWindowSize(java.lang.Integer producerWindowSize)
producerWindowSize
- The valuepublic java.lang.Integer getProducerMaxRate()
public void setProducerMaxRate(java.lang.Integer producerMaxRate)
producerMaxRate
- The valuepublic java.lang.Integer getMinLargeMessageSize()
public void setMinLargeMessageSize(java.lang.Integer minLargeMessageSize)
minLargeMessageSize
- The valuepublic java.lang.Boolean getBlockOnAcknowledge()
public void setBlockOnAcknowledge(java.lang.Boolean blockOnAcknowledge)
blockOnAcknowledge
- The valuepublic java.lang.Boolean getBlockOnNonPersistentSend()
public void setBlockOnNonPersistentSend(java.lang.Boolean blockOnNonPersistentSend)
blockOnNonPersistentSend
- The valuepublic java.lang.Boolean getBlockOnPersistentSend()
public void setBlockOnPersistentSend(java.lang.Boolean blockOnPersistentSend)
blockOnPersistentSend
- The valuepublic java.lang.Boolean getAutoGroup()
public void setAutoGroup(java.lang.Boolean autoGroup)
autoGroup
- The valuepublic java.lang.Integer getMaxConnections()
public void setMaxConnections(java.lang.Integer maxConnections)
maxConnections
- The valuepublic java.lang.Boolean getPreAcknowledge()
public void setPreAcknowledge(java.lang.Boolean preAcknowledge)
preAcknowledge
- The valuepublic java.lang.Long getRetryInterval()
public void setRetryInterval(java.lang.Long retryInterval)
retryInterval
- The valuepublic java.lang.Double getRetryIntervalMultiplier()
public void setRetryIntervalMultiplier(java.lang.Double retryIntervalMultiplier)
retryIntervalMultiplier
- The valuepublic java.lang.Integer getReconnectAttempts()
public void setReconnectAttempts(java.lang.Integer reconnectAttempts)
reconnectAttempts
- The valuepublic java.lang.Boolean isFailoverOnServerShutdown()
public java.lang.Boolean getFailoverOnServerShutdown()
public void setFailoverOnServerShutdown(java.lang.Boolean failoverOnServerShutdown)
failoverOnServerShutdown
- The valuepublic java.lang.String getConnectionLoadBalancingPolicyClassName()
public void setConnectionLoadBalancingPolicyClassName(java.lang.String connectionLoadBalancingPolicyClassName)
public java.lang.Integer getScheduledThreadPoolMaxSize()
public void setScheduledThreadPoolMaxSize(java.lang.Integer scheduledThreadPoolMaxSize)
public java.lang.Integer getThreadPoolMaxSize()
public void setThreadPoolMaxSize(java.lang.Integer threadPoolMaxSize)
public java.lang.Boolean getUseGlobalPools()
public void setUseGlobalPools(java.lang.Boolean useGlobalPools)
public java.lang.String getUserName()
public void setUserName(java.lang.String userName)
userName
- The valuepublic java.lang.String getPassword()
public void setPassword(java.lang.String password)
password
- The valuepublic java.lang.String getClientID()
public void setClientID(java.lang.String clientID)
clientID
- The client idpublic java.lang.Boolean getUseLocalTx()
public void setUseLocalTx(java.lang.Boolean localTx)
localTx
- The valuepublic java.lang.Boolean getUseXA()
public void setUseXA(java.lang.Boolean xa)
xa
- The valuepublic boolean equals(java.lang.Object obj)
equals
in class java.lang.Object
obj
- Object with which to compare
public int hashCode()
hashCode
in class java.lang.Object
public javax.resource.spi.work.WorkManager getWorkManager()
public ClientSession createSession(ClientSessionFactory parameterFactory, int ackMode, java.lang.String user, java.lang.String pass, java.lang.Boolean preAck, java.lang.Integer dupsOkBatchSize, java.lang.Integer transactionBatchSize, boolean deliveryTransacted, boolean useLocalTx) throws java.lang.Exception
java.lang.Exception
protected JBMRAProperties getProperties()
protected void setup() throws MessagingException
MessagingException
public JBossConnectionFactory getDefaultJBossConnectionFactory() throws javax.resource.ResourceException
javax.resource.ResourceException
public JBossConnectionFactory createJBossConnectionFactory(ConnectionFactoryProperties overrideProperties)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |