1 files changed, 34 insertions, 34 deletions

diff --git a/feature-session-persistence/src/main/java/org/onap/policy/drools/persistence/JpaDroolsSessionConnector.java b/feature-session-persistence/src/main/java/org/onap/policy/drools/persistence/JpaDroolsSessionConnector.java
index 76c09681..cd76ae8d 100644
--- a/feature-session-persistence/src/main/java/org/onap/policy/drools/persistence/JpaDroolsSessionConnector.java
+++ b/feature-session-persistence/src/main/java/org/onap/policy/drools/persistence/JpaDroolsSessionConnector.java
@@ -26,14 +26,12 @@ import javax.persistence.EntityManagerFactory;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-
 public class JpaDroolsSessionConnector implements DroolsSessionConnector {
 
 	private static Logger logger = LoggerFactory.getLogger(JpaDroolsSessionConnector.class);
-		
+
 	private final EntityManagerFactory emf;
-	
-	
+
 	public JpaDroolsSessionConnector(EntityManagerFactory emf) {
 		this.emf = emf;
 	}
@@ -43,11 +41,11 @@ public class JpaDroolsSessionConnector implements DroolsSessionConnector {
 
 		EntityManager em = emf.createEntityManager();
 		DroolsSessionEntity s = null;
-		
-		try(EntityMgrTrans trans = new EntityMgrTrans(em)) {
-			
+
+		try (EntityMgrTrans trans = new EntityMgrTrans(em)) {
+
 			s = em.find(DroolsSessionEntity.class, sessName);
-			if(s != null) {
+			if (s != null) {
 				em.refresh(s);
 			}
 
@@ -60,57 +58,59 @@ public class JpaDroolsSessionConnector implements DroolsSessionConnector {
 	@Override
 	public void replace(DroolsSession sess) {
 		String sessName = sess.getSessionName();
-		
+
 		logger.info("replace: Entering and manually updating session name= {}", sessName);
-		
+
 		EntityManager em = emf.createEntityManager();
-		
-		try(EntityMgrTrans trans = new EntityMgrTrans(em)) {
-			
-			if( ! update(em, sess)) {
+
+		try (EntityMgrTrans trans = new EntityMgrTrans(em)) {
+
+			if (!update(em, sess)) {
 				add(em, sess);
 			}
-		
+
 			trans.commit();
 		}
-		
+
 		logger.info("replace: Exiting");
 	}
 
 	/**
 	 * Adds a session to the persistent store.
-	 * @param em	entity manager
-	 * @param sess	session to be added
+	 * 
+	 * @param em
+	 *            entity manager
+	 * @param sess
+	 *            session to be added
 	 */
 	private void add(EntityManager em, DroolsSession sess) {
 		logger.info("add: Inserting session id={}", sess.getSessionId());
 
-		DroolsSessionEntity ent =
-				new DroolsSessionEntity(
-						sess.getSessionName(),
-						sess.getSessionId());
-		
+		DroolsSessionEntity ent = new DroolsSessionEntity(sess.getSessionName(), sess.getSessionId());
+
 		em.persist(ent);
 	}
-	
+
 	/**
 	 * Updates a session, if it exists within the persistent store.
-	 * @param em	entity manager
-	 * @param sess	session data to be persisted
-	 * @return {@code true} if a record was updated, {@code false} if it
-	 * 			was not found
+	 * 
+	 * @param em
+	 *            entity manager
+	 * @param sess
+	 *            session data to be persisted
+	 * @return {@code true} if a record was updated, {@code false} if it was not
+	 *         found
 	 */
 	private boolean update(EntityManager em, DroolsSession sess) {
-		
-		DroolsSessionEntity s =
-				em.find(DroolsSessionEntity.class, sess.getSessionName());
-		if(s == null) {
+
+		DroolsSessionEntity s = em.find(DroolsSessionEntity.class, sess.getSessionName());
+		if (s == null) {
 			return false;
 		}
 
 		logger.info("update: Updating session id to {}", sess.getSessionId());
-		s.setSessionId( sess.getSessionId());
-		
+		s.setSessionId(sess.getSessionId());
+
 		return true;
 	}
 }