package com.c2kernel.collection; import java.util.StringTokenizer; import com.c2kernel.common.ObjectNotFoundException; import com.c2kernel.entity.proxy.ItemProxy; 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.CastorHashMap; import com.c2kernel.utils.KeyValuePair; import com.c2kernel.utils.Logger; /** * @version $Revision: 1.10 $ $Date: 2004/10/21 08:02:23 $ * @author $Author: abranson $ */ public class DependencyMember implements CollectionMember { private int mSystemKey = -1; private ItemProxy mItem = null; private int mId = -1; private CastorHashMap mProperties = null; private String mClassProps; /************************************************************************** * **************************************************************************/ public DependencyMember() { mSystemKey = -1; mProperties = new CastorHashMap(); } @Override public void setSystemKey(int sysKey) { mSystemKey = sysKey; mItem = null; } @Override public int getSystemKey() { return mSystemKey; } @Override public void setProperties(CastorHashMap props) { mProperties = props; } @Override public CastorHashMap getProperties() { return mProperties; } public KeyValuePair[] getKeyValuePairs() { return mProperties.getKeyValuePairs(); } public void setKeyValuePairs(KeyValuePair[] pairs) { mProperties.setKeyValuePairs(pairs); } @Override public int getID() { return mId; } @Override public void setID(int id) { mId = id; } @Override public void setClassProps(String props) { mClassProps = props; } @Override public String getClassProps() { return mClassProps; } @Override public void assignItem(int ItemKey) throws MembershipException { if (ItemKey > -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(ItemKey, ClusterStorage.PROPERTY+"/"+aClassProp, null); if (ItemProperty == null) throw new MembershipException("Property "+aClassProp+ " does not exist for ItemKey=" + ItemKey ); if (!ItemProperty.getValue().equalsIgnoreCase(memberValue)) throw new MembershipException("DependencyMember::checkProperty() Values of mandatory prop "+aClassProp+" do not match " + ItemProperty.getValue()+"!="+memberValue); } catch (Exception ex) { Logger.error(ex); throw new MembershipException("Error checking properties"); } } } mSystemKey = ItemKey; mItem = 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; } }