[jboss-svn-commits] JBL Code SVN: r34209 - labs/jbossrules/trunk/drools-container/drools-spring/src/main/java/org/drools/container/spring/beans/persistence.

[jboss-svn-commits at lists.jboss.org]

Author: mark.proctor at jboss.com
Date: 2010-07-26 16:49:09 -0400 (Mon, 26 Jul 2010)
New Revision: 34209

Removed:
   labs/jbossrules/trunk/drools-container/drools-spring/src/main/java/org/drools/container/spring/beans/persistence/JPAKnowledgeServiceBean.java
Log:
JBRULES-2593 JPAKnowledgeServiceBean does not initialize JPAKnowledgeFactoryService
-Removed JPAKnowledgeServiceBean

Deleted: labs/jbossrules/trunk/drools-container/drools-spring/src/main/java/org/drools/container/spring/beans/persistence/JPAKnowledgeServiceBean.java
===================================================================
--- labs/jbossrules/trunk/drools-container/drools-spring/src/main/java/org/drools/container/spring/beans/persistence/JPAKnowledgeServiceBean.java	2010-07-26 20:48:27 UTC (rev 34208)
+++ labs/jbossrules/trunk/drools-container/drools-spring/src/main/java/org/drools/container/spring/beans/persistence/JPAKnowledgeServiceBean.java	2010-07-26 20:49:09 UTC (rev 34209)
@@ -1,151 +0,0 @@
-package org.drools.container.spring.beans.persistence;
-
-import java.util.Collections;
-import java.util.Map;
-
-import javax.persistence.EntityManager;
-import javax.persistence.PersistenceException;
-
-import org.drools.KnowledgeBase;
-import org.drools.KnowledgeBaseFactoryService;
-import org.drools.base.MapGlobalResolver;
-import org.drools.builder.JPAKnowledgeFactoryService;
-import org.drools.grid.ExecutionNode;
-import org.drools.grid.local.LocalConnection;
-import org.drools.persistence.processinstance.VariablePersistenceStrategyFactory;
-import org.drools.persistence.processinstance.persisters.VariablePersister;
-import org.drools.runtime.Environment;
-import org.drools.runtime.EnvironmentName;
-import org.drools.runtime.StatefulKnowledgeSession;
-import org.springframework.orm.jpa.JpaCallback;
-import org.springframework.orm.jpa.support.JpaDaoSupport;
-import org.springframework.transaction.TransactionStatus;
-import org.springframework.transaction.support.AbstractPlatformTransactionManager;
-import org.springframework.transaction.support.TransactionCallback;
-import org.springframework.transaction.support.TransactionTemplate;
-
-public class JPAKnowledgeServiceBean extends JpaDaoSupport {
-
-    private ExecutionNode                                        node;
-    private KnowledgeBase                                        kbase;
-    private JPAKnowledgeFactoryService                           jpaKnowledgeServiceProvider;
-    private Environment                                          environment;
-    private AbstractPlatformTransactionManager                   transactionManager;
-    private Map<Class< ? >, Class< ? extends VariablePersister>> variablePersisters = Collections.emptyMap();
-
-    public StatefulKnowledgeSession newStatefulKnowledgeSession() {
-        TransactionTemplate txTemplate = new TransactionTemplate( transactionManager );
-        return (StatefulKnowledgeSession) txTemplate.execute( new TransactionCallback() {
-            public Object doInTransaction(TransactionStatus status) {
-                return getJpaTemplate().execute( new JpaCallback() {
-                    public StatefulKnowledgeSession doInJpa(EntityManager em) throws PersistenceException {
-                        return jpaKnowledgeServiceProvider.newStatefulKnowledgeSession( kbase,
-                                                                                        null,
-                                                                                        environment );
-                    }
-                } );
-            }
-        } );
-    }
-
-    public StatefulKnowledgeSession loadStatefulKnowledgeSession(final int sessionId) {
-        TransactionTemplate txTemplate = new TransactionTemplate( transactionManager );
-        return (StatefulKnowledgeSession) txTemplate.execute( new TransactionCallback() {
-            public Object doInTransaction(TransactionStatus status) {
-                return getJpaTemplate().execute( new JpaCallback() {
-                    public StatefulKnowledgeSession doInJpa(EntityManager em) throws PersistenceException {
-                        return jpaKnowledgeServiceProvider.loadStatefulKnowledgeSession( sessionId,
-                                                                                         kbase,
-                                                                                         null,
-                                                                                         environment );
-                    }
-                } );
-            }
-        } );
-    }
-
-    @Override
-    protected void initDao() {
-        if ( kbase == null ) {
-            throw new IllegalArgumentException( "property kbase is mandatory" );
-        }
-        if ( node == null ) {
-            LocalConnection connection = new LocalConnection();
-            node = connection.getExecutionNode( null );
-        }
-        if ( environment == null ) {
-            environment = node.get( KnowledgeBaseFactoryService.class ).newEnvironment();
-        }
-        if ( environment.get( EnvironmentName.ENTITY_MANAGER_FACTORY ) != null ) {
-            logger.debug( "overwriting environment key: " + EnvironmentName.ENTITY_MANAGER_FACTORY );
-        }
-        environment.set( EnvironmentName.ENTITY_MANAGER_FACTORY,
-                         getJpaTemplate().getEntityManagerFactory() );
-        if ( environment.get( EnvironmentName.TRANSACTION_MANAGER ) != null ) {
-            logger.debug( "overwriting environment key: " + EnvironmentName.TRANSACTION_MANAGER );
-        }
-        environment.set( EnvironmentName.TRANSACTION_MANAGER,
-                         getTransactionManager() );
-        environment.set( EnvironmentName.GLOBALS,
-                         new MapGlobalResolver() );
-
-//        jpaKnowledgeServiceProvider = node.get( JPAKnowledgeFactoryService.class );
-//        if ( jpaKnowledgeServiceProvider instanceof JPAKnowledgeProviderLocalClient ) {
-//            JPAKnowledgeProviderLocalClient local = (JPAKnowledgeProviderLocalClient) jpaKnowledgeServiceProvider;
-//            local.setCommandServiceClass( SpringSingleSessionCommandService.class );
-//        } else {
-//            throw new RuntimeDroolsException( "JPAKnowledgeService is not instance of: " + JPAKnowledgeProviderLocalClient.class.getName() );
-//        }
-
-        if ( variablePersisters != null && !variablePersisters.isEmpty() ) {
-            for ( Map.Entry<Class< ? >, Class< ? extends VariablePersister>> entry : variablePersisters.entrySet() ) {
-                VariablePersistenceStrategyFactory.getVariablePersistenceStrategy().setPersister( entry.getKey().getName(),
-                                                                                                  entry.getValue().getName() );
-            }
-        }
-        //		serviceManager.JPAKnowledgeService().loadStatefulKnowledgeSession(0, 
-        //					serviceManager.getKnowledgeBaseFactory().newKnowledgeBase(), 
-        //					null, 
-        //					environment);
-    }
-
-    public KnowledgeBase getKbase() {
-        return kbase;
-    }
-
-    public void setKbase(KnowledgeBase kbase) {
-        this.kbase = kbase;
-    }
-
-    public ExecutionNode getExecutionNode() {
-        return node;
-    }
-
-    public void setExecutionNode(ExecutionNode node) {
-        this.node = node;
-    }
-
-    public Environment getEnvironment() {
-        return environment;
-    }
-
-    public void setEnvironment(Environment environment) {
-        this.environment = environment;
-    }
-
-    public AbstractPlatformTransactionManager getTransactionManager() {
-        return transactionManager;
-    }
-
-    public void setTransactionManager(AbstractPlatformTransactionManager transactionManager) {
-        this.transactionManager = transactionManager;
-    }
-
-    public void setVariablePersisters(Map<Class< ? >, Class< ? extends VariablePersister>> variablePersisters) {
-        this.variablePersisters = variablePersisters;
-    }
-
-    public Map<Class< ? >, Class< ? extends VariablePersister>> getVariablePersisters() {
-        return variablePersisters;
-    }
-}