fbascheper/oracle-aq-connector

Simple Oracle AQ connector for Tomcat

Oracle AQ connector

A simple connector to use ConnectionFactories for Oracle AQ in Tomcat

---

Tomcat configuration

You will need to update your Tomcat configuration files in order to use the following JNDI references:

• java:/comp/env/jdbc/myDS
• java:/comp/env/jms/aqQueueConnectionFactory

Notes

1. Tomcat does not ship with A JTA implementation and/or XA transaction manager, but you will need one to use an XADataSource or XAQueueConnectionFactory.
2. If you are looking for an open source JTA-implementation, check out Atomikos Essentials.

Add global resources in server.xml

  <GlobalNamingResources>
    <Resource name="java:/comp/env/jdbc/myDS" auth="Container"
                  type="oracle.jdbc.xa.client.OracleXADataSource"
                  description="Oracle XA Datasource"
                  factory="oracle.jdbc.pool.OracleDataSourceFactory"
                  url="jdbc:oracle:thin:@dbhost:1521:XE"
                  userName="user"
                  password="passwd"
    />

    <Resource name="java:/comp/env/jms/aqQueueConnectionFactory" auth="Container"
                  type="javax.jms.XAQueueConnectionFactory"
                  description="Oracle AQ queue connection-factory"
                  factory="com.github.fbascheper.oracle.aq.OracleAQSourceFactory"
                  refDataSourceFactory="oracle.jdbc.pool.OracleDataSourceFactory"
                  refDataSourceType="oracle.jdbc.xa.client.OracleXADataSource"
                  url="jdbc:oracle:thin:@dbhost:1521:XE"
                  userName="aquser"
                  password="aqpasswd"
    />
  </GlobalNamingResources>

Add resource links in config.xml

<Context>
    <ResourceLink name="jdbc/myDS"
                  global="java:/comp/env/jdbc/myDS"
                  type="javax.sql.XADataSource" />

    <ResourceLink name="jms/aqQueueConnectionFactory"
	              global="java:/comp/env/jms/aqQueueConnectionFactory"
				  type="javax.jms.XAQueueConnectionFactory" />
</Context>

Spring sample code to retrieve the XAQueueConnectionFactory from JNDI

public class ConnectionFactories {
    
    @Bean(name = "aqQueueConnectionFactory")
    public XAQueueConnectionFactory aqQueueConnectionFactory() {
        XAQueueConnectionFactory qcf;

        try {
            qcf = (XAQueueConnectionFactory) new JndiTemplate().lookup("java:/comp/env/jms/aqQueueConnectionFactory");
        } catch (NamingException e) {
            throw new IllegalStateException("Failed to lookup QCF", e);
        }

        return qcf;
    }
}