<?xml version="1.0" encoding="UTF-8"?>
<persistence xmlns="http://java.sun.com/xml/ns/persistence" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" version="2.0" xsi:schemaLocation="http://java.sun.com/xml/ns/persistence http://java.sun.com/xml/ns/persistence/persistence_2_0.xsd">
<persistence-unit name="ExperimentjndiPU" transaction-type="JTA">
<provider>org.eclipse.persistence.jpa.PersistenceProvider</provider>
<jta-data-source>ExperimentOra</jta-data-source>
<properties>
<property name="eclipselink.session.customizer" value="uk.co.his.experiment.eclipselink.Customizer"/>
<property name="eclipselink.logging.level" value="FINE"/>
<property name="eclipselink.logging.session" value="true"/>
<property name="eclipselink.cache.shared.default" value="false"/>
</properties>
</persistence-unit>
</persistence>

<jdbc-connection-pool driver-classname="" datasource-classname="oracle.jdbc.xa.client.OracleXADataSource" res-type="javax.sql.XADataSource" description="" name="oracle_ExperimentPool" ping="true">
<property name="internal_logon" value="sysdba"/>
<property name="User" value="xxxx"/>
<property name="DatabaseName" value="orcl"/>
<property name="Password" value="xxxx"/>
<property name="DataSourceName" value="OracleXADataSource"/>
<property name="ServerName" value="lil"/>
<property name="ExplicitCachingEnabled" value="false"/>
<property name="MaxStatements" value="0"/>
<property name="NativeXA" value="false"/>
<property name="NetworkProtocol" value="tcp"/>
<property name="ImplicitCachingEnabled" value="false"/>
<property name="PortNumber" value="1521"/>
<property name="LoginTimeout" value="0"/>
<property name="URL" value="jdbc:oracle:thin:xxxx/xxxx@lil:1521:orcl"/>
</jdbc-connection-pool>
<jdbc-resource pool-name="oracle_ExperimentPool" description="" jndi-name="ExperimentOra"/>
</resources>

@Entity
public class Person {
	@Id
	private String id;
	
	private String name;
	
	
	public static Person createNewInstance()
	{
		Person p = new Person();
		p.setIdFromUUID();
		return p;
	}
	
	@ElementCollection
	private List<String> comments = new ArrayList<String>();

	public String getId() {
		return id;
	}

	public void setId(String id) {
		this.id = id;
	}
	
	public void setIdFromUUID()
	{
		id = java.util.UUID.randomUUID().toString();
	}

	public String getName() {
		return name;
	}

	public void setName(String name) {
		this.name = name;
	}
	
	public void addComment(String comment)
	{
		comments.add(comment);
	}
	
	public List<String> getComments()
	{
		return Collections.unmodifiableList(comments);
	}

	@Override
	public String toString() {
		@SuppressWarnings("unused")
		String superRes = super.toString();
		StringBuilder str = new StringBuilder();
		str.append("id: " + id + ", ");
		str.append("name: " + name + ", ");
		str.append("comments: \n");
		for (String comment : comments) {
			str.append("\tcomment: " + comment + "\n");
		}
		return str.toString();
	}
	
}

package uk.co.his.experiment.eclipselink;

...imports deleted

public class Customizer implements org.eclipse.persistence.config.SessionCustomizer {
	
	public Customizer()
	{
		System.err.println("The Customizer has been started");
	}

	@Override
	public void customize(Session session) throws Exception {
		System.err.println("Customize a " + session);
		System.err.println("Customize session called " + session.getName());
	}

}

package uk.co.his.experiment;

import java.net.InetAddress;
import java.net.UnknownHostException;
import java.util.List;

import javax.ejb.LocalBean;
import javax.ejb.Stateless;
import javax.naming.NamingException;
import javax.persistence.EntityManager;
import javax.persistence.LockModeType;
import javax.persistence.PersistenceContext;
import javax.persistence.TypedQuery;
import javax.transaction.SystemException;


/**
 * Session Bean implementation class BeanA
 */
@Stateless(mappedName = "BeanA")
@LocalBean
public class BeanA implements BeanARemote {

	@PersistenceContext(name="ExperimentjndiPU")
	EntityManager em;
	
	/*@Resource(mappedName="java:appserver/TransactionManager") //java:appserver/TransactionManager"
	private TransactionManager txManager;*/
	
    /**
     * Default constructor. 
     */
    public BeanA() {
        // TODO Auto-generated constructor stub
    }


	private String getContextInfo() throws SystemException
	{
		StringBuilder str = new StringBuilder();
		str.append("Thread: " + Thread.currentThread().getName() + ":" + Thread.currentThread().getId() + "\n");
		str.append("EntityManager delegate: " + em.getDelegate() + "\n");
		return str.toString();
	}

	private static final boolean useEclipseLinkBeginEarly = true;
	@SuppressWarnings("unused")
	@Override
	public void function3(boolean writeBeforeReading) throws NamingException, SystemException {
		System.out.println("Entering BeanA::function3:\n"  + getContextInfo() + "\n" );


		
		String hostname = "Unknown";
		try {
			hostname = InetAddress.getLocalHost().getCanonicalHostName();
		} catch (UnknownHostException e) {
		}
		
		if(writeBeforeReading)
		{
			Person p = Person.createNewInstance();
			p.setName("Created in A function 3 on " + hostname);
			p.addComment("Normally called inside the same EAR running on a DIFFERENT box - 1 of 2 created in this function");
			em.persist(p);
			em.flush();
		}
		
		
		String people = getPeople(em);
		System.out.println("People in BeanA function3:");
		System.out.println(people);
		
		Person p2 = Person.createNewInstance();
		p2.setName("Created in A function 3 on " + hostname);
		if(writeBeforeReading )
		{
			p2.addComment("Normally called inside the same EAR running on a DIFFERENT box - 2nd of 2 created in this function");
		}
		else
		{
			p2.addComment("Normally called inside the same EAR running on a DIFFERENT box");
		}
		em.persist(p2);
		em.flush();

		System.out.println("Exiting BeanA::function3:\n"  + getContextInfo() + "\n" );
	}
	
	private String getPeople(EntityManager em)
	{
		StringBuilder str = new StringBuilder();
		TypedQuery<Person> q = em.createQuery("select x from Person x", Person.class);
		//!!Commented Out....q.setLockMode(LockModeType.PESSIMISTIC_READ); !!
		List<Person> results = q.getResultList();
		for (Person person : results) {
			str.append("Found Person " + person + "\n");
		}
		if(results.isEmpty())
		{
			str.append("Nobody was found");
		}
		return str.toString();
	}

}

package uk.co.his.experiment;

import java.net.InetAddress;
import java.net.UnknownHostException;
import java.util.List;

import javax.ejb.EJB;
import javax.ejb.LocalBean;
import javax.ejb.Stateless;
import javax.naming.NamingException;
import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;
import javax.persistence.TypedQuery;
import javax.transaction.SystemException;

import uk.co.his.experiment2.BeanXRemote;
import uk.co.his.experiment2.BeanYRemote;

/**
 * Session Bean implementation class BeanB
 */
@Stateless(mappedName = "BeanB")
@LocalBean
public class BeanB implements BeanBRemote {

	@PersistenceContext(name="ExperimentjndiPU")
	EntityManager em;
	

	@EJB(mappedName="BeanX")
    private BeanXRemote beanX;
	

    /**
     * Default constructor. 
     */
    public BeanB() {
        // TODO Auto-generated constructor stub
    }

	@Override
	public void function5(boolean writeBeforeReading) throws NamingException, SystemException
	{
		String hostname = "Unknown";
		try {
			hostname = InetAddress.getLocalHost().getCanonicalHostName();
		} catch (UnknownHostException e) {
		}

		System.out.println("BeanB function5 start");
		
		
		Person p = Person.createNewInstance();
		p.setName("Created in B function 5 on " + hostname);
		p.addComment("The only person created directly in the 'controller' bean");
		em.persist(p);
		em.flush();
		{
			String str = getPeople(em);
			System.out.println("People in BeanB function5 before calling X");
			System.out.println(str);
			System.out.println("end get people before calling X");
		}

		System.out.println("Calling X locally");
		try
		{
			beanX.functionXR(writeBeforeReading);
		}
		finally
		{
			System.out.println("Called X locally");
		}
		try
		{
			String str = getPeople(em);
			System.out.println("People in BeanB function5 after first X call - expect " + (writeBeforeReading?"two":"one") + " person from liepa");
			System.out.println(str);
			System.out.println("end get people");
		}
		finally
		{

			System.out.println("BeanB function5 getPeople 1");
		}
		
		System.out.println("Calling X locally 2");
		try
		{
			beanX.functionXR(writeBeforeReading);
		}
		finally
		{
			System.out.println("Called X locally 2");
		}
		try
		{
			String str = getPeople(em);
			System.out.println("People in BeanB function5 final - expect " + (writeBeforeReading?"four":"two") + " people from liepa");
			System.out.println(str);
			System.out.println("end get people");
		}
		finally
		{

			System.out.println("BeanB function5 end");
		}
	}
	
	private String getPeople(EntityManager em)
	{
		StringBuilder str = new StringBuilder();
		TypedQuery<Person> q = em.createQuery("select x from Person x", Person.class);
		List<Person> results = q.getResultList();
		for (Person person : results) {
			str.append("Found Person " + person + "\n");
		}
		if(results.isEmpty())
		{
			str.append("Nobody was found");
		}
		return str.toString();
	}
}

@EJB(mappedName="BeanB")
	private BeanBRemote beanBr;

	private void test18() throws NamingException, NotSupportedException, SystemException, SecurityException, IllegalStateException, RollbackException, HeuristicMixedException, HeuristicRollbackException {
		System.out.println("ControllerServlet test18 start");
		try
		{
			beanBr.function5(false);
			System.out.println("ControllerServlet BeanB function5 called");
		}
		finally
		{
			System.out.println("ControllerServlet test18 end");
		}
	}
	
	private void test19() throws NamingException, NotSupportedException, SystemException, SecurityException, IllegalStateException, RollbackException, HeuristicMixedException, HeuristicRollbackException {
		System.out.println("ControllerServlet test18 start");
		try
		{
			beanBr.function5(true);
			System.out.println("ControllerServlet BeanB function5 called");
		}
		finally
		{
			System.out.println("ControllerServlet test18 end");
		}
	}

package uk.co.his.experiment2;

import javax.ejb.EJB;
import javax.ejb.LocalBean;
import javax.ejb.Stateless;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import javax.transaction.SystemException;

import uk.co.his.experiment.BeanARemote;

/**
 * Session Bean implementation class BeanX
 */
@Stateless(mappedName = "BeanX")
@LocalBean
public class BeanX implements BeanXRemote {

        @EJB(mappedName="corbaname:iiop:liepa:3700#BeanA")
    private BeanARemote beanAr;
	/**
     * Default constructor. 
     */
    public BeanX() {
        // TODO Auto-generated constructor stub
    }


	@Override
	public void functionXR(boolean writeBeforeReading) throws NamingException, SystemException {
		System.out.println("Calling A on liepa!");
		beanAr.function3(writeBeforeReading);
		System.out.println("Called A on liepa!");
	}
}

private static final boolean useEclipseLinkBeginEarly = true;
	@SuppressWarnings("unused")
	@Override
	public void function3(boolean writeBeforeReading) throws NamingException, SystemException {
		System.out.println("Entering BeanA::function3:\n"  + getContextInfo() + "\n" );

		if(useEclipseLinkBeginEarly)
		{
			Session session = SessionManager.getManager().getSession("file:/C:/Users/Administrator/workspace/glassfish31eclipsedefaultdomain/eclipseApps/ExperimentEAR/lib/ExperimentEARmodel.jar/_ExperimentjndiPU");
			if(session != null)
			{
					session = session.getActiveSession();
					UnitOfWork work = session.getActiveUnitOfWork();
					work.beginEarlyTransaction();
					System.out.println("Unit of work beginEarlyTransaction called - read on a transactional connection");
			}
			else
			{
				System.err.println("Default session is null");
			}
		}
		else
		{
			System.out.println("Doing the default Eclipselink thing - read on a non transactional connection");
		}
		
		String hostname = "Unknown";
		try {
			hostname = InetAddress.getLocalHost().getCanonicalHostName();
		} catch (UnknownHostException e) {
		}
		
		if(writeBeforeReading && (!useEclipseLinkBeginEarly))
		{
			Person p = Person.createNewInstance();
			p.setName("Created in A function 3 on " + hostname);
			p.addComment("Normally called inside the same EAR running on a DIFFERENT box - 1 of 2 created in this function");
			em.persist(p);
			em.flush();
		}
		
		
		String people = getPeople(em);
		System.out.println("People in BeanA function3:");
		System.out.println(people);
		
		Person p2 = Person.createNewInstance();
		p2.setName("Created in A function 3 on " + hostname);
		if(writeBeforeReading && (!useEclipseLinkBeginEarly))
		{
			p2.addComment("Normally called inside the same EAR running on a DIFFERENT box - 2nd of 2 created in this function");
		}
		else
		{
			p2.addComment("Normally called inside the same EAR running on a DIFFERENT box");
		}
		em.persist(p2);
		em.flush();

		System.out.println("Exiting BeanA::function3:\n"  + getContextInfo() + "\n" );
	}