public final class ActiveMQRAManagedConnectionFactory extends Object implements javax.resource.spi.ManagedConnectionFactory, javax.resource.spi.ResourceAdapterAssociation
Constructor and Description |
---|
ActiveMQRAManagedConnectionFactory()
Constructor
|
Modifier and Type | Method and Description |
---|---|
Object |
createConnectionFactory()
Creates a Connection Factory instance
|
Object |
createConnectionFactory(javax.resource.spi.ConnectionManager cxManager)
Creates a Connection Factory instance
|
javax.resource.spi.ManagedConnection |
createManagedConnection(Subject subject,
javax.resource.spi.ConnectionRequestInfo cxRequestInfo)
Creates a new physical connection to the underlying EIS resource manager.
|
boolean |
equals(Object obj)
Indicates whether some other object is "equal to" this one.
|
Long |
getCallTimeout() |
Long |
getClientFailureCheckPeriod() |
String |
getClientID() |
Integer |
getConfirmationWindowSize() |
String |
getConnectionLoadBalancingPolicyClassName() |
String |
getConnectionParameters() |
Long |
getConnectionTTL() |
String |
getConnectorClassName() |
Integer |
getConsumerMaxRate() |
Integer |
getConsumerWindowSize() |
String |
getDiscoveryAddress() |
Long |
getDiscoveryInitialWaitTimeout() |
Integer |
getDiscoveryPort() |
Long |
getDiscoveryRefreshTimeout() |
Integer |
getDupsOKBatchSize() |
PrintWriter |
getLogWriter()
Get the log writer -- NOT SUPPORTED
|
javax.jms.ConnectionMetaData |
getMetaData()
Get the connection metadata
|
Integer |
getMinLargeMessageSize() |
Integer |
getProducerMaxRate() |
protected ActiveMQRAMCFProperties |
getProperties()
Get the managed connection factory properties
|
Integer |
getReconnectAttempts() |
javax.resource.spi.ResourceAdapter |
getResourceAdapter()
Get the resource adapter
|
XARecoveryConfig |
getResourceRecovery() |
Long |
getRetryInterval() |
Double |
getRetryIntervalMultiplier() |
Integer |
getScheduledThreadPoolMaxSize() |
String |
getSessionDefaultType()
Get the default session type
|
Integer |
getThreadPoolMaxSize() |
Integer |
getTransactionBatchSize() |
Integer |
getUseTryLock()
Get the useTryLock.
|
int |
hashCode()
Return the hash code for the object
|
Boolean |
isAutoGroup() |
Boolean |
isBlockOnAcknowledge() |
Boolean |
isBlockOnDurableSend() |
Boolean |
isBlockOnNonDurableSend() |
Boolean |
isHA() |
Boolean |
isPreAcknowledge() |
Boolean |
isUseGlobalPools() |
javax.resource.spi.ManagedConnection |
matchManagedConnections(Set connectionSet,
Subject subject,
javax.resource.spi.ConnectionRequestInfo cxRequestInfo)
Returns a matched connection from the candidate set of connections.
|
void |
setAutoGroup(Boolean autoGroup) |
void |
setBlockOnAcknowledge(Boolean blockOnAcknowledge) |
void |
setBlockOnDurableSend(Boolean blockOnDurableSend) |
void |
setBlockOnNonDurableSend(Boolean blockOnNonDurableSend) |
void |
setCallTimeout(Long callTimeout) |
void |
setClientFailureCheckPeriod(Long clientFailureCheckPeriod) |
void |
setClientID(String clientID) |
void |
setConfirmationWindowSize(Integer confirmationWindowSize) |
void |
setConnectionLoadBalancingPolicyClassName(String connectionLoadBalancingPolicyClassName) |
void |
setConnectionParameters(String configuration) |
void |
setConnectionTTL(Long connectionTTL) |
void |
setConnectorClassName(String value) |
void |
setConsumerMaxRate(Integer consumerMaxRate) |
void |
setConsumerWindowSize(Integer consumerWindowSize) |
void |
setDiscoveryAddress(String discoveryAddress) |
void |
setDiscoveryInitialWaitTimeout(Long discoveryInitialWaitTimeout) |
void |
setDiscoveryPort(Integer discoveryPort) |
void |
setDiscoveryRefreshTimeout(Long discoveryRefreshTimeout) |
void |
setDupsOKBatchSize(Integer dupsOKBatchSize) |
void |
setHA(Boolean ha) |
void |
setLogWriter(PrintWriter out)
Set the log writer -- NOT SUPPORTED
|
void |
setMinLargeMessageSize(Integer minLargeMessageSize) |
void |
setPreAcknowledge(Boolean preAcknowledge) |
void |
setProducerMaxRate(Integer producerMaxRate) |
void |
setReconnectAttempts(Integer reconnectAttempts) |
void |
setResourceAdapter(javax.resource.spi.ResourceAdapter ra)
Set the resource adapter
This should ensure that when the RA is stopped, this MCF will be stopped as well. |
void |
setRetryInterval(Long retryInterval) |
void |
setRetryIntervalMultiplier(Double retryIntervalMultiplier) |
void |
setScheduledThreadPoolMaxSize(Integer scheduledThreadPoolMaxSize) |
void |
setSessionDefaultType(String type)
Set the default session type
|
void |
setThreadPoolMaxSize(Integer threadPoolMaxSize) |
void |
setTransactionBatchSize(Integer transactionBatchSize) |
void |
setUseGlobalPools(Boolean useGlobalPools) |
void |
setUseTryLock(Integer useTryLock)
Set the useTryLock.
|
void |
stop() |
public ActiveMQRAManagedConnectionFactory()
public Object createConnectionFactory() throws javax.resource.ResourceException
createConnectionFactory
in interface javax.resource.spi.ManagedConnectionFactory
javax.resource.ResourceException
- Thrown if a connection factory can't be createdpublic Object createConnectionFactory(javax.resource.spi.ConnectionManager cxManager) throws javax.resource.ResourceException
createConnectionFactory
in interface javax.resource.spi.ManagedConnectionFactory
cxManager
- The connection managerjavax.resource.ResourceException
- Thrown if a connection factory can't be createdpublic javax.resource.spi.ManagedConnection createManagedConnection(Subject subject, javax.resource.spi.ConnectionRequestInfo cxRequestInfo) throws javax.resource.ResourceException
createManagedConnection
in interface javax.resource.spi.ManagedConnectionFactory
subject
- Caller's security informationcxRequestInfo
- Additional resource adapter specific connection request informationjavax.resource.ResourceException
- Thrown if a managed connection can't be createdpublic XARecoveryConfig getResourceRecovery()
public javax.resource.spi.ManagedConnection matchManagedConnections(Set connectionSet, Subject subject, javax.resource.spi.ConnectionRequestInfo cxRequestInfo) throws javax.resource.ResourceException
matchManagedConnections
in interface javax.resource.spi.ManagedConnectionFactory
connectionSet
- The candidate connection setsubject
- Caller's security informationcxRequestInfo
- Additional resource adapter specific connection request informationjavax.resource.ResourceException
- Thrown if the managed connection can not be foundpublic void setLogWriter(PrintWriter out) throws javax.resource.ResourceException
setLogWriter
in interface javax.resource.spi.ManagedConnectionFactory
out
- The writerjavax.resource.ResourceException
- Thrown if the writer can't be setpublic PrintWriter getLogWriter() throws javax.resource.ResourceException
getLogWriter
in interface javax.resource.spi.ManagedConnectionFactory
javax.resource.ResourceException
- Thrown if the writer can't be retrievedpublic javax.resource.spi.ResourceAdapter getResourceAdapter()
getResourceAdapter
in interface javax.resource.spi.ResourceAdapterAssociation
public void setResourceAdapter(javax.resource.spi.ResourceAdapter ra) throws javax.resource.ResourceException
setResourceAdapter
in interface javax.resource.spi.ResourceAdapterAssociation
ra
- The resource adapterjavax.resource.ResourceException
- Thrown if incorrect resource adapterpublic boolean equals(Object obj)
public int hashCode()
public String getSessionDefaultType()
public void setSessionDefaultType(String type)
type
- either javax.jms.Topic or javax.jms.Queuepublic String getConnectionParameters()
public void setConnectionParameters(String configuration)
public String getConnectorClassName()
public void setConnectorClassName(String value)
public String getConnectionLoadBalancingPolicyClassName()
public void setConnectionLoadBalancingPolicyClassName(String connectionLoadBalancingPolicyClassName)
public String getDiscoveryAddress()
public void setDiscoveryAddress(String discoveryAddress)
public Integer getDiscoveryPort()
public void setDiscoveryPort(Integer discoveryPort)
public Long getDiscoveryRefreshTimeout()
public void setDiscoveryRefreshTimeout(Long discoveryRefreshTimeout)
public Long getDiscoveryInitialWaitTimeout()
public void setDiscoveryInitialWaitTimeout(Long discoveryInitialWaitTimeout)
public String getClientID()
public void setClientID(String clientID)
public Integer getDupsOKBatchSize()
public void setDupsOKBatchSize(Integer dupsOKBatchSize)
public Integer getTransactionBatchSize()
public void setTransactionBatchSize(Integer transactionBatchSize)
public Long getClientFailureCheckPeriod()
public void setClientFailureCheckPeriod(Long clientFailureCheckPeriod)
public Long getConnectionTTL()
public void setConnectionTTL(Long connectionTTL)
public Long getCallTimeout()
public void setCallTimeout(Long callTimeout)
public Integer getConsumerWindowSize()
public void setConsumerWindowSize(Integer consumerWindowSize)
public Integer getConsumerMaxRate()
public void setConsumerMaxRate(Integer consumerMaxRate)
public Integer getConfirmationWindowSize()
public void setConfirmationWindowSize(Integer confirmationWindowSize)
public Integer getProducerMaxRate()
public void setProducerMaxRate(Integer producerMaxRate)
public Integer getMinLargeMessageSize()
public void setMinLargeMessageSize(Integer minLargeMessageSize)
public Boolean isBlockOnAcknowledge()
public void setBlockOnAcknowledge(Boolean blockOnAcknowledge)
public Boolean isBlockOnNonDurableSend()
public void setBlockOnNonDurableSend(Boolean blockOnNonDurableSend)
public Boolean isBlockOnDurableSend()
public void setBlockOnDurableSend(Boolean blockOnDurableSend)
public Boolean isAutoGroup()
public void setAutoGroup(Boolean autoGroup)
public Boolean isPreAcknowledge()
public void setPreAcknowledge(Boolean preAcknowledge)
public Long getRetryInterval()
public void setRetryInterval(Long retryInterval)
public Double getRetryIntervalMultiplier()
public void setRetryIntervalMultiplier(Double retryIntervalMultiplier)
public Integer getReconnectAttempts()
public void setReconnectAttempts(Integer reconnectAttempts)
public Boolean isUseGlobalPools()
public void setUseGlobalPools(Boolean useGlobalPools)
public Integer getScheduledThreadPoolMaxSize()
public void setScheduledThreadPoolMaxSize(Integer scheduledThreadPoolMaxSize)
public Integer getThreadPoolMaxSize()
public void setThreadPoolMaxSize(Integer threadPoolMaxSize)
public Boolean isHA()
public void setHA(Boolean ha)
public Integer getUseTryLock()
public void setUseTryLock(Integer useTryLock)
useTryLock
- the useTryLock.public javax.jms.ConnectionMetaData getMetaData()
protected ActiveMQRAMCFProperties getProperties()
public void stop()
Copyright © 2016 The Apache Software Foundation. All rights reserved.