[gatein-commits] gatein SVN: r2207 - in portal/trunk/component/wsrp/src/main/java/org/gatein/portal/wsrp/state: producer/registrations and 1 other directory.

[do-not-reply at jboss.org]

Author: chris.laprun at jboss.com
Date: 2010-03-12 06:22:29 -0500 (Fri, 12 Mar 2010)
New Revision: 2207

Modified:
   portal/trunk/component/wsrp/src/main/java/org/gatein/portal/wsrp/state/JCRPersister.java
   portal/trunk/component/wsrp/src/main/java/org/gatein/portal/wsrp/state/producer/registrations/JCRRegistrationPersistenceManager.java
Log:
- Added save method on JCRPersister so that we can save independently of closing the session as it might be needed.
- Do not close the session before iterating over the elements to populate internal state of JCRRegistrationPersistenceManager.

Modified: portal/trunk/component/wsrp/src/main/java/org/gatein/portal/wsrp/state/JCRPersister.java
===================================================================
--- portal/trunk/component/wsrp/src/main/java/org/gatein/portal/wsrp/state/JCRPersister.java	2010-03-12 10:14:43 UTC (rev 2206)
+++ portal/trunk/component/wsrp/src/main/java/org/gatein/portal/wsrp/state/JCRPersister.java	2010-03-12 11:22:29 UTC (rev 2207)
@@ -95,7 +95,12 @@
       session.close();
    }
 
+   public void save(ChromatticSession session)
+   {
+      session.save();
+   }
 
+
    public static class WSRPSessionLifeCycle implements SessionLifeCycle
    {
       private ManageableRepository repository;

Modified: portal/trunk/component/wsrp/src/main/java/org/gatein/portal/wsrp/state/producer/registrations/JCRRegistrationPersistenceManager.java
===================================================================
--- portal/trunk/component/wsrp/src/main/java/org/gatein/portal/wsrp/state/producer/registrations/JCRRegistrationPersistenceManager.java	2010-03-12 10:14:43 UTC (rev 2206)
+++ portal/trunk/component/wsrp/src/main/java/org/gatein/portal/wsrp/state/producer/registrations/JCRRegistrationPersistenceManager.java	2010-03-12 11:22:29 UTC (rev 2207)
@@ -73,7 +73,7 @@
       {
          mappings = session.insert(ConsumersAndGroupsMapping.class, ConsumersAndGroupsMapping.NODE_NAME);
       }
-      persister.closeSession(session, true);
+      persister.save(session); // needed right now as the session must still be open to iterate over nodes
 
       for (ConsumerGroupMapping cgm : mappings.getConsumerGroups())
       {
@@ -91,6 +91,8 @@
             internalAddRegistration((RegistrationSPI)registration);
          }
       }
+
+      persister.closeSession(session, false);
    }
 
    @Override