[gatein-commits] gatein SVN: r2207 - in portal/trunk/component/wsrp/src/main/java/org/gatein/portal/wsrp/state: producer/registrations and 1 other directory.
Author: chris.laprun(a)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