package com.c2kernel.collection; import java.util.StringTokenizer; import com.c2kernel.common.ObjectNotFoundException; import com.c2kernel.entity.proxy.ItemProxy; import com.c2kernel.graph.model.GraphableVertex; import com.c2kernel.lookup.ItemPath; import com.c2kernel.lookup.InvalidItemPathException; import com.c2kernel.persistency.ClusterStorage; import com.c2kernel.process.Gateway; import com.c2kernel.property.Property; import com.c2kernel.utils.Logger; /** * @version $Revision: 1.11 $ $Date: 2005/12/01 14:23:15 $ * @author $Author: abranson $ */ //this extends Vertex for inherit the graph visualization //this does not implement MemberObject anylonger. it is a java object. //eventually the member object corba interface will be phased out. public class AggregationMember extends GraphableVertex implements CollectionMember { private int mSystemKey = -1; private ItemProxy mItem = null; private Aggregation mCollection = null; private String mClassProps = null; String ItemName; /************************************************************************** * **************************************************************************/ public AggregationMember() { super(); mSystemKey = -1; mCollection = null; } @Override public void setSystemKey(int sysKey) { mSystemKey = sysKey; ItemName = null; } public void setCollection(Aggregation aggregation) { mCollection = aggregation; } @Override public void setClassProps(String props) { mClassProps = props; } @Override public int getSystemKey() { return mSystemKey; } public Aggregation getCollection() { return mCollection; } @Override public String getClassProps() { return mClassProps; } @Override public void assignItem(int sysKey) throws MembershipException { if (sysKey > -1) { if (mClassProps == null || getProperties() == null) throw new MembershipException("ClassProps not yet set. Cannot check membership validity."); //for each mandatory prop check if its in the member property and has the matching value StringTokenizer sub = new StringTokenizer(mClassProps, ","); while (sub.hasMoreTokens()) { String aClassProp = sub.nextToken(); try { String memberValue = (String)getProperties().get(aClassProp); Property ItemProperty = (Property)Gateway.getStorage().get(sysKey, ClusterStorage.PROPERTY+"/"+aClassProp, null); if (ItemProperty == null) throw new MembershipException("Property "+aClassProp+ " does not exist for sysKey=" + sysKey ); if (ItemProperty.getValue() == null || !ItemProperty.getValue().equalsIgnoreCase(memberValue)) throw new MembershipException("Value of mandatory prop "+aClassProp+" does not match: " + ItemProperty.getValue()+"!="+memberValue); } catch (MembershipException ex) { throw ex; } catch (Exception ex) { Logger.error(ex); throw new MembershipException("Error checking properties"); } } } mSystemKey = sysKey; mItem = null; ItemName = null; } @Override public void clearItem() { mSystemKey = -1; mItem = null; } @Override public ItemProxy resolveItem() throws ObjectNotFoundException { if (mItem == null) { try { ItemPath path = new ItemPath(mSystemKey); mItem = Gateway.getProxyManager().getProxy(path); } catch (InvalidItemPathException ex) { throw new ObjectNotFoundException("No member defined", ""); } } return mItem; } public String getItemName() { if (ItemName == null) { if (mSystemKey > -1) { try { ItemName = resolveItem().getName(); } catch (ObjectNotFoundException ex) { Logger.error(ex); ItemName = "Error ("+mSystemKey+")"; } } else ItemName = "Empty"; } return ItemName; } }