public class QpidResourceAdapter extends Object implements javax.resource.spi.ResourceAdapter, Serializable
Constructor and Description |
---|
QpidResourceAdapter() |
Modifier and Type | Method and Description |
---|---|
AMQConnectionFactory |
createAMQConnectionFactory(ConnectionFactoryProperties overrideProperties) |
javax.jms.Session |
createSession(AMQConnection connection,
int ackMode,
boolean useLocalTx,
Integer prefetchLow,
Integer prefetchHigh) |
javax.jms.XASession |
createXASession(XAConnectionImpl connection) |
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.
|
String |
getClientId()
Get the client ID
|
String |
getConnectionURL()
Get the connection url
|
AMQConnectionFactory |
getDefaultAMQConnectionFactory() |
String |
getHost()
Get the host
|
String |
getPassword() |
String |
getPath()
Get the connection url
|
Integer |
getPort()
Get the port
|
protected QpidRAProperties |
getProperties()
Get the resource adapter properties
|
Integer |
getSetupAttempts() |
Long |
getSetupInterval() |
TransactionManager |
getTM() |
String |
getTransactionManagerLocatorClass()
Get the transaction manager locator class
|
String |
getTransactionManagerLocatorMethod()
Get the transaction manager locator method
|
String |
getUserName() |
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 |
isUseConnectionPerHandler() |
Boolean |
isUseLocalTx()
Get the use XA flag
|
Map<String,Object> |
overrideConnectionParameters(Map<String,Object> connectionParams,
Map<String,Object> overrideConnectionParams) |
void |
setClientId(String clientID)
Set the client ID
|
void |
setConnectionURL(String connectionURL)
Set the client ID
|
void |
setHost(String host)
Set the host
|
void |
setPassword(String password) |
void |
setPath(String path)
Set the client ID
|
void |
setPort(Integer port)
Set the client ID
|
void |
setSetupAttempts(Integer setupAttempts) |
void |
setSetupInterval(Long interval) |
void |
setTransactionManagerLocatorClass(String locator)
Set the transaction manager locator class
|
void |
setTransactionManagerLocatorMethod(String method)
Set the transaction manager locator method
|
protected void |
setup()
Setup the factory
|
void |
setUseConnectionPerHandler(Boolean connectionPerHandler) |
void |
setUseLocalTx(Boolean localTx)
Set the use XA flag
|
void |
setUserName(String userName) |
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 String getClientId()
public void setClientId(String clientID)
clientID
- The client idpublic String getHost()
public void setHost(String host)
host
- The hostpublic Integer getPort()
public void setPort(Integer port)
port
- The portpublic String getPath()
public void setPath(String path)
path
- The pathpublic String getUserName()
public void setUserName(String userName)
public String getPassword()
public void setPassword(String password)
public String getConnectionURL()
public void setConnectionURL(String connectionURL)
connectionURL
- The connection urlpublic String getTransactionManagerLocatorClass()
public void setTransactionManagerLocatorClass(String locator)
locator
- The transaction manager locator classpublic String getTransactionManagerLocatorMethod()
public void setTransactionManagerLocatorMethod(String method)
method
- The transaction manager locator methodpublic Boolean isUseLocalTx()
public void setUseLocalTx(Boolean localTx)
localTx
- The valuepublic Integer getSetupAttempts()
public void setSetupAttempts(Integer setupAttempts)
public Long getSetupInterval()
public void setSetupInterval(Long interval)
public Boolean isUseConnectionPerHandler()
public void setUseConnectionPerHandler(Boolean connectionPerHandler)
public boolean equals(Object obj)
public int hashCode()
public javax.resource.spi.work.WorkManager getWorkManager()
public javax.jms.XASession createXASession(XAConnectionImpl connection) throws Exception
Exception
public javax.jms.Session createSession(AMQConnection connection, int ackMode, boolean useLocalTx, Integer prefetchLow, Integer prefetchHigh) throws Exception
Exception
protected QpidRAProperties getProperties()
protected void setup() throws QpidRAException
QpidRAException
public AMQConnectionFactory getDefaultAMQConnectionFactory() throws javax.resource.ResourceException
javax.resource.ResourceException
public AMQConnectionFactory createAMQConnectionFactory(ConnectionFactoryProperties overrideProperties) throws QpidRAException
QpidRAException
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.