Repackage to org.cristalise

1 files changed, 0 insertions, 158 deletions

diff --git a/src/main/java/com/c2kernel/persistency/ProxyLoader.java b/src/main/java/com/c2kernel/persistency/ProxyLoader.java
deleted file mode 100644
index 88b6f03..0000000
--- a/src/main/java/com/c2kernel/persistency/ProxyLoader.java
+++ /dev/null
@@ -1,158 +0,0 @@
-/**

- * This file is part of the CRISTAL-iSE kernel.

- * Copyright (c) 2001-2014 The CRISTAL Consortium. All rights reserved.

- *

- * This library is free software; you can redistribute it and/or modify it

- * under the terms of the GNU Lesser General Public License as published

- * by the Free Software Foundation; either version 3 of the License, or (at

- * your option) any later version.

- *

- * This library is distributed in the hope that it will be useful, but WITHOUT

- * ANY WARRANTY; with out even the implied warranty of MERCHANTABILITY or

- * FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public

- * License for more details.

- *

- * You should have received a copy of the GNU Lesser General Public License

- * along with this library; if not, write to the Free Software Foundation,

- * Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA.

- *

- * http://www.fsf.org/licensing/licenses/lgpl.html

- */

-package com.c2kernel.persistency;

-import java.util.HashMap;

-import java.util.StringTokenizer;

-

-import com.c2kernel.common.ObjectNotFoundException;

-import com.c2kernel.common.PersistencyException;

-import com.c2kernel.entity.AgentHelper;

-import com.c2kernel.entity.C2KLocalObject;

-import com.c2kernel.entity.Item;

-import com.c2kernel.entity.ItemHelper;

-import com.c2kernel.lookup.ItemPath;

-import com.c2kernel.lookup.Lookup;

-import com.c2kernel.persistency.outcome.Outcome;

-import com.c2kernel.process.Gateway;

-import com.c2kernel.process.auth.Authenticator;

-import com.c2kernel.utils.Logger;

-

-/** Used by proxies to load clusters by queryData from the Entity.

-*   Last client storage - only used if not cached elsewhere

-*/

-

-public class ProxyLoader extends ClusterStorage {

-    HashMap<ItemPath, Item> entities = new HashMap<ItemPath, Item>();

-    Lookup lookup;

-

-    @Override

-	public void open(Authenticator auth) throws PersistencyException {

-        lookup = Gateway.getLookup();

-    }

-

-    @Override

-	public void close() throws PersistencyException {

-    }

-    // introspection

-    @Override

-	public short queryClusterSupport(String clusterType) {

-        return READ;

-    }

-

-    @Override

-	public String getName() {

-        return "Proxy Cluster Loader";

-    }

-

-    @Override

-	public String getId() {

-        return "CORBA";

-    }

-

-    // retrieve object by path

-    @Override

-	public C2KLocalObject get(ItemPath thisItem, String path) throws PersistencyException {

-        try {

-            Item thisEntity = getIOR(thisItem);

-            String type = getClusterType(path);

-

-            // fetch the xml from the item

-            String queryData = thisEntity.queryData(path);

-            if (Logger.doLog(6)) Logger.msg(6, "ProxyLoader - "+thisItem+":"+path+" = "+queryData);

-

-            if (queryData != null) {

-                if (type.equals(OUTCOME))

-                    return new Outcome(path, queryData);

-                else

-                    return (C2KLocalObject)Gateway.getMarshaller().unmarshall(queryData);

-            }

-        } catch (ObjectNotFoundException e) {

-        	return null;

-        } catch (Exception e) {

-            Logger.error(e);

-            throw new PersistencyException(e.getMessage());

-        }

-        return null;

-    }

-

-    // store object by path

-    @Override

-	public void put(ItemPath thisItem, C2KLocalObject obj) throws PersistencyException {

-        // not supported

-        throw new PersistencyException("Cannot write to items through the ProxyLoader");

-    }

-    // delete cluster

-    @Override

-	public void delete(ItemPath thisItem, String path) throws PersistencyException {

-        // not supported

-        throw new PersistencyException("Cannot write to items through the ProxyLoader");

-    }

-

-    /* navigation */

-

-    // directory listing

-    @Override

-	public String[] getClusterContents(ItemPath thisItem, String path) throws PersistencyException {

-        try {

-            Item thisEntity = getIOR(thisItem);

-            String contents = thisEntity.queryData(path+"/all");

-            StringTokenizer tok = new StringTokenizer(contents, ",");

-            String[] result = new String[tok.countTokens()];

-            for (int i=0; i<result.length; i++)

-                result[i] = tok.nextToken();

-

-            return result;

-        } catch (Exception e) {

-        	Logger.error(e);

-            throw new PersistencyException(e.getMessage());

-        }

-    }

-

-    private Item getIOR(ItemPath thisPath) throws PersistencyException {

-        if (entities.containsKey(thisPath)) {

-            // check the cache

-            Logger.msg(7, "ProxyLoader.getIOR() - "+thisPath+" cached.");

-            return entities.get(thisPath);

-        }

-

-        try {

-            Logger.msg(7, "ProxyLoader.getIOR() - Resolving "+thisPath+".");

-            org.omg.CORBA.Object ior = lookup.resolve(thisPath);

-

-            Item thisItem = null;

-            try {

-            	thisItem = ItemHelper.narrow(ior);

-            } catch (org.omg.CORBA.BAD_PARAM ex) {

-                try {

-                	thisItem =  AgentHelper.narrow(ior);

-                } catch (org.omg.CORBA.BAD_PARAM ex2) {

-                    throw new PersistencyException ("Could not narrow "+thisItem+" as a known Entity type");

-                }

-            }

-

-            Logger.msg(7, "ProxyLoader.getIOR() - Found "+thisItem+".");

-            entities.put(thisPath, thisItem);

-            return thisItem;

-        } catch (Exception e) {

-            throw new PersistencyException("Error narrowing "+thisPath+": "+e.getMessage());

-        }

-    }

-}