<persistence-unit name="myPU" transaction-type="JTA">
<provider>org.eclipse.persistence.jpa.PersistenceProvider</provider>
		
		<jta-data-source>
			<![CDATA[
			osgi:javax.sql.DataSource/(name=ManagedDemoDs)
			]]>
		</jta-data-source>
		
		<non-jta-data-source>
			<![CDATA[
			osgi:javax.sql.DataSource/(name=DemoDs)
			]]>
		</non-jta-data-source>
		
    	<class>persistence.service.simple.SimplePersonService</class>
		
		<properties>
			<property name="javax.persistence.jdbc.driver" value="org.postgresql.Driver" />
			<property name="javax.persistence.jdbc.url" value="jdbc:postgres://10.50.10.15:5432/test" />
			<property name="javax.persistence.jdbc.user" value="user" />
			<property name="javax.persistence.jdbc.password" value="pwd" />
			
			<property name="eclipselink.logging.level" value="ALL" />

			<!-- EclipseLink specific properties -->
			<property name="eclipselink.ddl-generation" value="createtables" />
			<property name="eclipselink.ddl-generation.output-mode" value="database" />

    		<property name="hibernate.dialect" value="org.hibernate.dialect.PostgreSQLDialect"/> <!-- DB Dialect -->
            <property name="hibernate.hbm2ddl.auto" value="update" /> <!-- create / create-drop / update -->
            
            <property name="hibernate.show_sql" value="true" /> <!-- Show SQL in console -->
            <property name="hibernate.format_sql" value="true" /> <!-- Show SQL formatted -->
		</properties>
	</persistence-unit>

/**
 * 
 */
package persistence.service.simple;

import java.util.Properties;

import javax.persistence.EntityManagerFactory;

import org.apache.felix.dm.Component;
import org.apache.felix.dm.DependencyActivatorBase;
import org.apache.felix.dm.DependencyManager;
import org.osgi.framework.BundleActivator;
import org.osgi.framework.BundleContext;

/**
 * @author afatdsprod\rayburnj
 *
 */
public class Activator 
	extends DependencyActivatorBase
	implements BundleActivator
{

	@Override
	public void init(BundleContext context, DependencyManager manager) throws Exception 
	{
	    Properties props = new Properties();
	    props.put("transactional", SimplePersonService.class.getName());

	    Component comp = createComponent()
	                    .setInterface(Object.class.getName(), props)
	                    .setImplementation(SimplePersonService.class)
	                    .add(createServiceDependency()
	                            .setService(
	                                EntityManagerFactory.class, "(osgi.unit.name=myPU)")
	                            .setRequired(true));
	    
		manager.add(comp);
		
	}
}

package persistence.service.simple;

import java.util.ArrayList;
import java.util.List;

import javax.persistence.EntityManager;
import javax.persistence.EntityManagerFactory;
import javax.persistence.Persistence;
import javax.persistence.PersistenceContext;
import javax.transaction.Transactional;

import org.apache.felix.dm.annotation.api.Component;
import org.apache.felix.dm.annotation.api.Property;
import org.apache.felix.dm.annotation.api.ServiceDependency;

import persistence.api.Person;
import persistence.api.Team;

@Transactional
@Component(
    properties=@Property(name="persistent", value="true"))
public class SimplePersonService 
	implements Team
{
	private List<Person> listPersons = new ArrayList<>();
	
	@ServiceDependency
	private volatile EntityManager em;
	
	public SimplePersonService()
	{
	}
	
	@Override
	public List<Person> listPersons() {
		//List<Person> persons = em.fin
		// TODO Auto-generated method stub
		return listPersons;
	}

	@Override
	public void addPerson(Person person) {
		// update
		System.out.println("em="+em);;
		System.out.println("Created "+person.getName());
		
		listPersons().add(person);
	}

	public void start()
	{
		addPerson(new Person("Devoxx", "Antwerp", "me@test1.com", "555-555-5555"));
		addPerson(new Person("Jfokus", "Stockholm", "me@test2.com", "555-555-6666"));
		
		System.out.println("Total of " + listPersons().size() + " persons");
	}
}

% telnet 10.50.10.15 5432