Package org.apache.activemq.ra

Class SimpleConnectionManager

java.lang.Object

org.apache.activemq.ra.SimpleConnectionManager

All Implemented Interfaces:

jakarta.resource.spi.ConnectionEventListener, jakarta.resource.spi.ConnectionManager, Serializable, EventListener

public class SimpleConnectionManager
extends Object
implements jakarta.resource.spi.ConnectionManager, jakarta.resource.spi.ConnectionEventListener

A simple implementation of a ConnectionManager. An Application Server will have a better implementation with pooling and security etc.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
SimpleConnectionManager()

Method Summary

Modifier and Type	Method	Description
Object	allocateConnection(jakarta.resource.spi.ManagedConnectionFactory connectionFactory, jakarta.resource.spi.ConnectionRequestInfo info)
void	connectionClosed(jakarta.resource.spi.ConnectionEvent event)
void	connectionErrorOccurred(jakarta.resource.spi.ConnectionEvent event)
void	localTransactionCommitted(jakarta.resource.spi.ConnectionEvent event)
void	localTransactionRolledback(jakarta.resource.spi.ConnectionEvent event)
void	localTransactionStarted(jakarta.resource.spi.ConnectionEvent event)

Methods inherited from class java.lang.Object

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

Constructor Details

SimpleConnectionManager

public SimpleConnectionManager()

Method Details

allocateConnection

public Object allocateConnection(jakarta.resource.spi.ManagedConnectionFactory connectionFactory,
 jakarta.resource.spi.ConnectionRequestInfo info)
                          throws jakarta.resource.ResourceException

Specified by:

allocateConnection in interface jakarta.resource.spi.ConnectionManager

Throws:

jakarta.resource.ResourceException

See Also:

• javax.resource.spi.ConnectionManager#allocateConnection(javax.resource.spi.ManagedConnectionFactory, javax.resource.spi.ConnectionRequestInfo)

connectionClosed

public void connectionClosed(jakarta.resource.spi.ConnectionEvent event)

Specified by:

connectionClosed in interface jakarta.resource.spi.ConnectionEventListener

See Also:

• javax.resource.spi.ConnectionEventListener#connectionClosed(javax.resource.spi.ConnectionEvent)

localTransactionStarted

public void localTransactionStarted(jakarta.resource.spi.ConnectionEvent event)

Specified by:

localTransactionStarted in interface jakarta.resource.spi.ConnectionEventListener

See Also:

• javax.resource.spi.ConnectionEventListener#localTransactionStarted(javax.resource.spi.ConnectionEvent)

localTransactionCommitted

public void localTransactionCommitted(jakarta.resource.spi.ConnectionEvent event)

Specified by:

localTransactionCommitted in interface jakarta.resource.spi.ConnectionEventListener

See Also:

• javax.resource.spi.ConnectionEventListener#localTransactionCommitted(javax.resource.spi.ConnectionEvent)

localTransactionRolledback

public void localTransactionRolledback(jakarta.resource.spi.ConnectionEvent event)

Specified by:

localTransactionRolledback in interface jakarta.resource.spi.ConnectionEventListener

See Also:

• javax.resource.spi.ConnectionEventListener#localTransactionRolledback(javax.resource.spi.ConnectionEvent)

connectionErrorOccurred

public void connectionErrorOccurred(jakarta.resource.spi.ConnectionEvent event)

Specified by:

connectionErrorOccurred in interface jakarta.resource.spi.ConnectionEventListener

See Also:

• javax.resource.spi.ConnectionEventListener#connectionErrorOccurred(javax.resource.spi.ConnectionEvent)