narayana-geode-core

Geode/Gemfire integration with Standalone JTA Narayana

Library that helps to run Geode/Gemfire as a Last Resource Commit in a global JTA transactions run by a standalone Narayana JTA server.

It uses the SingletonNamingServer standalone JNDI server to bind the Narayana TransactionManager under java:/TransactionManager.

To enlist the Geode as Last Resource Commit, from within the global transaction run: NarayanaGeodeSupport.enlistGeodeAsLastCommitResource().

A simple implementation would look like this:

private static NamingBeanImpl jndiServer = new NamingBeanImpl();

    public static void main(String[] args) throws Exception {

        // Bootstrap a standalone JNDI server
        SingletonNamingServer jndiServer = new SingletonNamingServer();

        // Bind JTA TM implementations with default names. Concerning Geode, this bind will register the
        // Narayana Transaction Manager under name "java:/TransactionManager".
        JNDIManager.bindJTAImplementation();
                
        // Obtain a Geode Region instance.
        // .........
        
        // Start Narayana JTA transaction.
        UserTransaction jta = com.arjuna.ats.jta.UserTransaction.userTransaction();
        jta.begin();
        
        // Enlist Geode as Last Resource Commit Resource.
        NarayanaGeodeSupport.enlistGeodeAsLastCommitResource();

        // Create and use other global transaction resources (JPA, JMS ...).
        // .........
        
        // Perform Geode put
        region.put("666", 666);

        // Commit the Narayana JTA transaction.
        jta.commit();

        // Stop the JNDI server.
        jndiServer.destroy();
    }

Check SimpleApplication.java for a complete example.