/eu.etaxonomy.taxeditor.cdmlib/src/main/java/eu/etaxonomy/taxeditor/session/CdmEntitySessionManager.java - Annotate - EDIT - EDIT Project Management

| Branch: | Tag: | Revision:

taxeditor/eu.etaxonomy.taxeditor.cdmlib/src/main/java/eu/etaxonomy/taxeditor/session/CdmEntitySessionManager.java @ abce4859

-afb673
+// $Id$
 /**
-            ba0d4c2f
+ * Copyright (C) 2014 EDIT
  * European Distributed Institute of Taxonomy
  * http://www.e-taxonomy.eu
+ *
  * The contents of this file are subject to the Mozilla Public License Version 1.1
  * See LICENSE.TXT at the top of this package for the full license terms.
  */
-afb673
+package eu.etaxonomy.taxeditor.session;
-e8efc
+import java.util.ArrayList;
-afb673
+import java.util.Collection;
 import java.util.HashMap;
-            ba0d4c2f
+import java.util.HashSet;
-e8efc
+import java.util.List;
-afb673
+import java.util.Map;
-            ba0d4c2f
+import java.util.Set;
-afb673
+            Cherian Mathew
 import org.apache.log4j.Logger;
 import org.springframework.stereotype.Component;
 import eu.etaxonomy.cdm.model.common.CdmBase;
-            ba0d4c2f
+import eu.etaxonomy.cdm.persistence.hibernate.CdmDataChangeEvent.EventType;
-afb673
+            Cherian Mathew
 /**
  * @author cmathew
  * @date 16 Oct 2014
+ *
  */
-            e78140b5
+@Component
-afb673
+public class CdmEntitySessionManager implements ICdmEntitySessionManager {
-            ba0d4c2f
+    private static final Logger logger = Logger.getLogger(CdmEntitySessionManager.class);
-afb673
+            Cherian Mathew
-e8efc
+    private final Map<ICdmEntitySessionEnabled, ICdmEntitySession> ownerSessionMap =
-            ba0d4c2f
+            new HashMap<ICdmEntitySessionEnabled, ICdmEntitySession>();
-e8efc
+            Cherian Mathew
     private final List<ICdmEntitySessionManagerObserver> sessionObservers = new ArrayList<ICdmEntitySessionManagerObserver>();
-            e78140b5
+            Cherian Mathew
-de230c
+    private ICdmEntitySession activeSession;
-ea8a
+            Cherian Mathew
-            ba0d4c2f
+            Cherian Mathew
-c6184af
+    @Override
-            ba0d4c2f
+    public ICdmEntitySession newSession(ICdmEntitySessionEnabled sessionOwner, boolean setAsActive) {
         ICdmEntitySession session = ownerSessionMap.get(sessionOwner);
         if(session == null) {
             session = new CdmEntitySession(sessionOwner, this);
             addToOwnerSessionMap(sessionOwner, session);
-e8efc
+            Cherian Mathew
-            ba0d4c2f
+            Cherian Mathew
-            e78140b5
+            Cherian Mathew
-            ba0d4c2f
+        if(setAsActive) {
             setActiveSession(session);
-e8efc
+            Cherian Mathew
-            ba0d4c2f
+            Cherian Mathew
-e8efc
+            Cherian Mathew
-            ba0d4c2f
+        return session;
+    }
-            e78140b5
+            Cherian Mathew
-c9343bd
+    @Override
     public ICdmEntitySession getActiveSession() {
         return activeSession;
+    }
-            ba0d4c2f
+    private void setActiveSession(ICdmEntitySession activeSession) {
         this.activeSession = activeSession;
-ea8a
+        notifyObservers();
-            ba0d4c2f
+            Cherian Mathew
-e8efc
+            Cherian Mathew
     /* (non-Javadoc)
      * @see eu.etaxonomy.taxeditor.session.ICdmEntitySessionManager#getSessions()
      */
     @Override
     public Collection<ICdmEntitySession> getSessions() {
         return ownerSessionMap.values();
+    }
-            ba0d4c2f
+    /* (non-Javadoc)
      * @see eu.etaxonomy.taxeditor.session.ICdmEntitySessionManager#bind(eu.etaxonomy.taxeditor.session.ISessionEventListener)
      */
     @Override
     public void bind(ICdmEntitySessionEnabled sessionOwner) {
         if(sessionOwner == null) {
             setActiveSession(null);
             return;
+        }
         ICdmEntitySession session  = ownerSessionMap.get(sessionOwner);
         if(session == null) {
             session = newSession(sessionOwner,true);
+        }
         setActiveSession(session);
+    }
     /* (non-Javadoc)
      * @see eu.etaxonomy.taxeditor.session.ICdmEntitySessionManager#load(T)
      */
     @Override
     public <T extends Object> T load(T obj, boolean update) {
         if(activeSession == null) {
             return obj;
         } else {
             return activeSession.load(obj, update);
+        }
+    }
     @Override
     public <T extends CdmBase> void update(T cdmBase, Set<CdmBase> affectedObjects) {
         if(activeSession != null) {
             activeSession.addEvent(cdmBase, affectedObjects, EventType.UPDATE);
+        }
+    }
     @Override
     public <T extends CdmBase> void update() {
         if(activeSession != null) {
             activeSession.update();
+        }
+    }
     /* (non-Javadoc)
      * @see eu.etaxonomy.taxeditor.session.ICdmEntitySessionManager#load(T)
      */
     @Override
     public <T extends CdmBase> T load(T cdmBase, boolean update) {
         if(activeSession == null) {
             return cdmBase;
+        }
         return activeSession.load(cdmBase, update);
+    }
     /* (non-Javadoc)
      * @see eu.etaxonomy.taxeditor.session.ICdmEntitySessionManager#load(java.util.Collection)
      */
     @Override
     public <T extends CdmBase> Collection<T> load(Collection<T> cdmBaseList, boolean update) {
         if(activeSession == null) {
             return cdmBaseList;
+        }
         return activeSession.load(cdmBaseList, update);
+    }
     /* (non-Javadoc)
      * @see eu.etaxonomy.taxeditor.session.ICdmEntitySessionManager#dispose(eu.etaxonomy.taxeditor.session.ISessionEventListener)
      */
     void remove(ICdmEntitySessionEnabled owner) {
         ICdmEntitySession session = ownerSessionMap.get(owner);
         if(session == null) {
             logger.info("No Session connected to owner, nothing to do");
             return;
+        }
         if(session == activeSession) {
             setActiveSession(null);
+        }
         ownerSessionMap.remove(owner);
+    }
     @Override
     public void dispose(ICdmEntitySessionEnabled owner) {
         ICdmEntitySession session = ownerSessionMap.get(owner);
         if(session != null) {
             session.dispose();
+        }
         notifyObservers();
+    }
     @Override
     public void disposeAll() {
         Set<ICdmEntitySessionEnabled> owners =
                 new HashSet<ICdmEntitySessionEnabled>(ownerSessionMap.keySet());
         for(ICdmEntitySessionEnabled owner : owners) {
             ICdmEntitySession session = ownerSessionMap.get(owner);
             if(session != null) {
                 session.dispose();
+            }
+        }
         notifyObservers();
+    }
     void addToOwnerSessionMap(ICdmEntitySessionEnabled owner, ICdmEntitySession session) {
         ownerSessionMap.put(owner, session);
+    }
-afb673
+            Cherian Mathew
-e8efc
+    /* (non-Javadoc)
      * @see eu.etaxonomy.taxeditor.session.ICdmEntitySessionManager#addSessionListener()
      */
     @Override
     public void addSessionObserver(ICdmEntitySessionManagerObserver sessionObserver) {
         sessionObservers.add(sessionObserver);
+    }
     public void notifyObservers() {
         for(ICdmEntitySessionManagerObserver sessionObserver : sessionObservers) {
             sessionObserver.changed();
+        }
+    }
     /* (non-Javadoc)
      * @see eu.etaxonomy.taxeditor.session.ICdmEntitySessionManager#isRemoting()
      */
     @Override
     public boolean isRemoting() {
         // FIXME:Remoting stupid method to check whether we are in remoting
         return true;
+    }
-afb673
+            Cherian Mathew

Project

General

Profile

EDIT