org.apache.qpid.ra

Class QpidResourceAdapter

java.lang.Object

org.apache.qpid.ra.QpidResourceAdapter

All Implemented Interfaces:

Serializable, javax.resource.spi.ResourceAdapter

public class QpidResourceAdapter
extends Object
implements javax.resource.spi.ResourceAdapter, Serializable

The resource adapter for Qpid

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
QpidResourceAdapter()

Method Summary

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

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

QpidResourceAdapter

public QpidResourceAdapter()

Method Detail

getTM

public TransactionManager getTM()

endpointActivation

public void endpointActivation(javax.resource.spi.endpoint.MessageEndpointFactory endpointFactory,
                               javax.resource.spi.ActivationSpec spec)
                        throws javax.resource.ResourceException

Endpoint activation

Specified by:

endpointActivation in interface javax.resource.spi.ResourceAdapter

Parameters:

endpointFactory - The endpoint factory

spec - The activation spec

Throws:

javax.resource.ResourceException - Thrown if an error occurs

endpointDeactivation

public void endpointDeactivation(javax.resource.spi.endpoint.MessageEndpointFactory endpointFactory,
                                 javax.resource.spi.ActivationSpec spec)

Endpoint deactivation

Specified by:

endpointDeactivation in interface javax.resource.spi.ResourceAdapter

Parameters:

endpointFactory - The endpoint factory

spec - The activation spec

getXAResources

public XAResource[] getXAResources(javax.resource.spi.ActivationSpec[] specs)
                            throws javax.resource.ResourceException

Get XA resources

Specified by:

getXAResources in interface javax.resource.spi.ResourceAdapter

Parameters:

specs - The activation specs

Returns:

The XA resources

Throws:

javax.resource.ResourceException - Thrown if an error occurs or unsupported

start

public void start(javax.resource.spi.BootstrapContext ctx)
           throws javax.resource.spi.ResourceAdapterInternalException

Start

Specified by:

start in interface javax.resource.spi.ResourceAdapter

Parameters:

ctx - The bootstrap context

Throws:

javax.resource.spi.ResourceAdapterInternalException - Thrown if an error occurs

stop

public void stop()

Stop

Specified by:

stop in interface javax.resource.spi.ResourceAdapter

getClientId

public String getClientId()

Get the client ID

Returns:

The value

setClientId

public void setClientId(String clientID)

Set the client ID

Parameters:

clientID - The client id

getHost

public String getHost()

Get the host

Returns:

The value

setHost

public void setHost(String host)

Set the host

Parameters:

host - The host

getPort

public Integer getPort()

Get the port

Returns:

The value

setPort

public void setPort(Integer port)

Set the client ID

Parameters:

port - The port

getPath

public String getPath()

Get the connection url

Returns:

The value

setPath

public void setPath(String path)

Set the client ID

Parameters:

path - The path

getUserName

public String getUserName()

setUserName

public void setUserName(String userName)

getPassword

public String getPassword()

setPassword

public void setPassword(String password)

getConnectionURL

public String getConnectionURL()

Get the connection url

Returns:

The value

setConnectionURL

public void setConnectionURL(String connectionURL)

Set the client ID

Parameters:

connectionURL - The connection url

getTransactionManagerLocatorClass

public String getTransactionManagerLocatorClass()

Get the transaction manager locator class

Returns:

The value

setTransactionManagerLocatorClass

public void setTransactionManagerLocatorClass(String locator)

Set the transaction manager locator class

Parameters:

locator - The transaction manager locator class

getTransactionManagerLocatorMethod

public String getTransactionManagerLocatorMethod()

Get the transaction manager locator method

Returns:

The value

setTransactionManagerLocatorMethod

public void setTransactionManagerLocatorMethod(String method)

Set the transaction manager locator method

Parameters:

method - The transaction manager locator method

isUseLocalTx

public Boolean isUseLocalTx()

Get the use XA flag

Returns:

The value

setUseLocalTx

public void setUseLocalTx(Boolean localTx)

Set the use XA flag

Parameters:

localTx - The value

getSetupAttempts

public Integer getSetupAttempts()

setSetupAttempts

public void setSetupAttempts(Integer setupAttempts)

getSetupInterval

public Long getSetupInterval()

setSetupInterval

public void setSetupInterval(Long interval)

isUseConnectionPerHandler

public Boolean isUseConnectionPerHandler()

setUseConnectionPerHandler

public void setUseConnectionPerHandler(Boolean connectionPerHandler)

equals

public boolean equals(Object obj)

Indicates whether some other object is "equal to" this one.

Overrides:

equals in class Object

Parameters:

obj - Object with which to compare

Returns:

True if this object is the same as the obj argument; false otherwise.

hashCode

public int hashCode()

Return the hash code for the object

Overrides:

hashCode in class Object

Returns:

The hash code

getWorkManager

public javax.resource.spi.work.WorkManager getWorkManager()

Get the work manager

Returns:

The manager

createXASession

public javax.jms.XASession createXASession(XAConnectionImpl connection)
                                    throws Exception

Throws:

Exception

createSession

public javax.jms.Session createSession(AMQConnection connection,
                                       int ackMode,
                                       boolean useLocalTx,
                                       Integer prefetchLow,
                                       Integer prefetchHigh)
                                throws Exception

Throws:

Exception

getProperties

protected QpidRAProperties getProperties()

Get the resource adapter properties

Returns:

The properties

setup

protected void setup()
              throws QpidRAException

Setup the factory

Throws:

QpidRAException

getDefaultAMQConnectionFactory

public AMQConnectionFactory getDefaultAMQConnectionFactory()
                                                    throws javax.resource.ResourceException

Throws:

javax.resource.ResourceException

createAMQConnectionFactory

public AMQConnectionFactory createAMQConnectionFactory(ConnectionFactoryProperties overrideProperties)
                                                throws QpidRAException

Throws:

QpidRAException

overrideConnectionParameters

public Map<String,Object> overrideConnectionParameters(Map<String,Object> connectionParams,
                                                       Map<String,Object> overrideConnectionParams)