db-ojb-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From arm...@apache.org
Subject cvs commit: db-ojb/src/java/org/apache/ojb/broker/accesslayer IndirectionHandler.java CollectionProxy.java
Date Tue, 28 Oct 2003 21:21:19 GMT
arminw      2003/10/28 13:21:19

  Modified:    src/java/org/apache/ojb/broker/core
                        PersistenceBrokerThreadMapping.java
               src/java/org/apache/ojb/broker/accesslayer
                        IndirectionHandler.java CollectionProxy.java
  Log:
  - throw exception if no PBKey is set, no longer
  return default PB in such a case to avoid unexpected
  behaviour
  
  - remove unused methods in PBTM
  
  Revision  Changes    Path
  1.4       +1 -33     db-ojb/src/java/org/apache/ojb/broker/core/PersistenceBrokerThreadMapping.java
  
  Index: PersistenceBrokerThreadMapping.java
  ===================================================================
  RCS file: /home/cvs/db-ojb/src/java/org/apache/ojb/broker/core/PersistenceBrokerThreadMapping.java,v
  retrieving revision 1.3
  retrieving revision 1.4
  diff -u -r1.3 -r1.4
  --- PersistenceBrokerThreadMapping.java	23 Jul 2003 20:06:56 -0000	1.3
  +++ PersistenceBrokerThreadMapping.java	28 Oct 2003 21:21:19 -0000	1.4
  @@ -77,7 +77,6 @@
        * The hashmap that maps PBKeys to current brokers for the thread
        **/
       private static ThreadLocal currentBrokerMap = new ThreadLocal();
  -    private static PBKey defaultPBKey;
   
       public static void setCurrentPersistenceBroker(PBKey key, PersistenceBroker broker)
            throws PBFactoryException
  @@ -118,19 +117,6 @@
           }
       }
   
  -    public static void setCurrentDefaultPersistenceBroker(PBKey key, PersistenceBroker
broker)
  -         throws PBFactoryException
  -    {
  -        defaultPBKey = key;
  -        setCurrentPersistenceBroker(key, broker);
  -    }
  -
  -    public static void setCurrentDefaultPersistenceBroker(PersistenceBroker broker)
  -         throws PBFactoryException
  -    {
  -        setCurrentPersistenceBroker(defaultPBKey, broker);
  -    }
  -
       /**
        * Return the current open {@link org.apache.ojb.broker.PersistenceBroker}
        * instance for the given {@link org.apache.ojb.broker.PBKey}, if any.
  @@ -172,22 +158,4 @@
           }
           return broker;
       }
  -
  -    /**
  -     * Return the current open default broker instance, if any.
  -     * @return null if no open {@link org.apache.ojb.broker.PersistenceBroker} found.
  -     */
  -    public static PersistenceBroker currentDefaultPersistenceBroker() throws PBFactoryException
  -    {
  -        if (defaultPBKey != null)
  -        {
  -            return currentPersistenceBroker(defaultPBKey);
  -        }
  -        else
  -        {
  -            return null;
  -        }
  -    }
  -
  -
   }
  
  
  
  1.21      +33 -37    db-ojb/src/java/org/apache/ojb/broker/accesslayer/IndirectionHandler.java
  
  Index: IndirectionHandler.java
  ===================================================================
  RCS file: /home/cvs/db-ojb/src/java/org/apache/ojb/broker/accesslayer/IndirectionHandler.java,v
  retrieving revision 1.20
  retrieving revision 1.21
  diff -u -r1.20 -r1.21
  --- IndirectionHandler.java	25 Oct 2003 23:59:26 -0000	1.20
  +++ IndirectionHandler.java	28 Oct 2003 21:21:19 -0000	1.21
  @@ -67,6 +67,7 @@
   import org.apache.ojb.broker.util.logging.Logger;
   import org.apache.ojb.broker.util.logging.LoggerFactory;
   import org.apache.ojb.broker.PBKey;
  +import org.apache.ojb.broker.OJBRuntimeException;
   
   //#ifdef JDK13
   import java.lang.reflect.InvocationHandler;
  @@ -86,7 +87,7 @@
       /**
        * reference to the used PersistenceBroker
        */
  -    private transient PersistenceBroker broker = null;
  +    private transient PersistenceBroker m_broker = null;
   	private PBKey brokerKey;
       /**
        * the real subject which this is hidden by the proxy
  @@ -168,42 +169,37 @@
       }
   
   	/**
  -	 * Gets the broker.
  -	 * If no BrokerKey is available return the Default Broker.
  -	 * @return a PersistenceBroker
  -	 */
  -    protected PersistenceBroker getBroker() throws PBFactoryException
  +     * Gets the broker.
  +     * If no PBKey is available a runtime exception will be thrown.
  +     * @return a PersistenceBroker
  +     */
  +    protected synchronized PersistenceBroker getBroker() throws PBFactoryException
       {
  -        PersistenceBroker currentBroker;
  -
  -        // first try to use the current broker to avoid blocking
  -        if (getBrokerKey() != null)
  +        PersistenceBroker broker;
  +        if (getBrokerKey() == null)
           {
  -            currentBroker = PersistenceBrokerThreadMapping.currentPersistenceBroker(getBrokerKey());
  -        }
  -        else
  +            /*
  +            arminw:
  +            if no PBKey is set we throw an exception, because we don't
  +            know which PB (connection) should be used.
  +            */
  +            throw new OJBRuntimeException("Can't find associated PBKey. Need PBKey to obtain
a valid" +
  +                    "PersistenceBroker instance from intern resources.");
  +        }
  +        // first try to use the current threaded broker to avoid blocking
  +        broker = PersistenceBrokerThreadMapping.currentPersistenceBroker(getBrokerKey());
  +        // current broker not found, create a intern new one
  +        if(broker == null)
           {
  -            currentBroker = PersistenceBrokerThreadMapping.currentDefaultPersistenceBroker();
  -        }
  -        if (currentBroker != null)
  -        {
  -            return currentBroker;
  +            if (m_broker == null)
  +            {
  +                m_broker = PersistenceBrokerFactory.createPersistenceBroker(getBrokerKey());
  +                // TODO: Better way?
  +                needsClose = true;
  +                broker = m_broker;
  +            }
           }
  -
  -        // the current broker not found, create a new one
  -	    if (broker == null)
  -	    {
  -	    	if (getBrokerKey() != null)
  -	    	{
  -				broker = PersistenceBrokerFactory.createPersistenceBroker(getBrokerKey());
  -	    	}
  -	    	else
  -	    	{
  -				broker = PersistenceBrokerFactory.defaultPersistenceBroker();
  -	    	}
  -            needsClose = true;
  -	    }
  -		return broker;
  +        return broker;
       }
   
       /**
  @@ -211,11 +207,11 @@
        */
       protected void releaseBroker()
       {
  -        if (broker != null && needsClose)
  +        if (m_broker != null && needsClose)
           {
           	needsClose = false;
  -            broker.close();
  -        	broker = null;
  +            m_broker.close();
  +        	m_broker = null;
           }
       }
   
  
  
  
  1.24      +321 -325  db-ojb/src/java/org/apache/ojb/broker/accesslayer/CollectionProxy.java
  
  Index: CollectionProxy.java
  ===================================================================
  RCS file: /home/cvs/db-ojb/src/java/org/apache/ojb/broker/accesslayer/CollectionProxy.java,v
  retrieving revision 1.23
  retrieving revision 1.24
  diff -u -r1.23 -r1.24
  --- CollectionProxy.java	25 Oct 2003 23:59:26 -0000	1.23
  +++ CollectionProxy.java	28 Oct 2003 21:21:19 -0000	1.24
  @@ -64,6 +64,7 @@
   import org.apache.ojb.broker.PersistenceBroker;
   import org.apache.ojb.broker.PersistenceBrokerException;
   import org.apache.ojb.broker.PersistenceBrokerFactory;
  +import org.apache.ojb.broker.OJBRuntimeException;
   import org.apache.ojb.broker.core.PersistenceBrokerThreadMapping;
   import org.apache.ojb.broker.query.Query;
   import org.apache.ojb.broker.util.collections.RemovalAwareCollection;
  @@ -78,12 +79,12 @@
    */
   public class CollectionProxy implements Collection, ManageableCollection
   {
  -	private transient PersistenceBroker m_broker;
  -	private PBKey m_brokerKey;
  -	private Query m_query;
  -	private Collection m_data;
  -	private Class m_collectionClass;
  -	private int m_size = -1;
  +    private transient PersistenceBroker m_broker;
  +    private PBKey m_brokerKey;
  +    private Query m_query;
  +    private Collection m_data;
  +    private Class m_collectionClass;
  +    private int m_size = -1;
       /*
       arminw
       fix a bug, caused by closing PB instances
  @@ -95,74 +96,74 @@
       private transient ArrayList m_listeners;
   
       public CollectionProxy(PBKey aKey, Query aQuery)
  -	{
  -		this(aKey, RemovalAwareCollection.class, aQuery);
  -	}
  -
  -	public CollectionProxy(PBKey aKey, Class aCollClass, Query aQuery)
  -	{
  -		setBrokerKey(aKey);
  -		setCollectionClass(aCollClass);
  -		setQuery(aQuery);
  -	}
  -
  -	public boolean isLoaded()
  -	{
  -		return m_data != null;
  -	}
  -
  -	/**
  -	 * do a count(*) with the query
  -	 */
  -	protected synchronized void loadSize() throws PersistenceBrokerException
  -	{
  -		try
  -		{
  -			m_size = getBroker().getCount(getQuery());
  -		}
  -		catch (Exception ex)
  -		{
  -			throw new PersistenceBrokerException(ex);
  -		}
  -		finally
  -		{
  -		    releaseBroker();
  -		}
  -	}
  -
  -	/**
  -	 * loads the data from the database, if count(*) returned > 0
  -	 */
  -	protected Collection loadData() throws PersistenceBrokerException
  -	{
  -		try
  -		{
  -			Collection result;
  +    {
  +        this(aKey, RemovalAwareCollection.class, aQuery);
  +    }
  +
  +    public CollectionProxy(PBKey aKey, Class aCollClass, Query aQuery)
  +    {
  +        setBrokerKey(aKey);
  +        setCollectionClass(aCollClass);
  +        setQuery(aQuery);
  +    }
  +
  +    public boolean isLoaded()
  +    {
  +        return m_data != null;
  +    }
  +
  +    /**
  +     * do a count(*) with the query
  +     */
  +    protected synchronized void loadSize() throws PersistenceBrokerException
  +    {
  +        try
  +        {
  +            m_size = getBroker().getCount(getQuery());
  +        }
  +        catch (Exception ex)
  +        {
  +            throw new PersistenceBrokerException(ex);
  +        }
  +        finally
  +        {
  +            releaseBroker();
  +        }
  +    }
  +
  +    /**
  +     * loads the data from the database, if count(*) returned > 0
  +     */
  +    protected Collection loadData() throws PersistenceBrokerException
  +    {
  +        try
  +        {
  +            Collection result;
               beforeLoading();
               if (m_data != null) // could be set by listener
               {
                   result = m_data;
               }
  -      		else if (m_size != 0)
  -      		{
  -        		result = (Collection) getBroker().getCollectionByQuery(getCollectionClass(),getQuery());
  -      		}
  -      		else
  -      		{
  -      			result = (Collection) getCollectionClass().newInstance();
  -      		}
  +            else if (m_size != 0)
  +            {
  +                result = (Collection) getBroker().getCollectionByQuery(getCollectionClass(),
getQuery());
  +            }
  +            else
  +            {
  +                result = (Collection) getCollectionClass().newInstance();
  +            }
               afterLoading();
  -			return result;
  -		}
  -		catch (Exception ex)
  -		{
  -			throw new PersistenceBrokerException(ex);
  -		}
  -		finally
  -		{
  -		    releaseBroker();
  -		}
  -	}
  +            return result;
  +        }
  +        catch (Exception ex)
  +        {
  +            throw new PersistenceBrokerException(ex);
  +        }
  +        finally
  +        {
  +            releaseBroker();
  +        }
  +    }
   
       protected void beforeLoading()
       {
  @@ -189,152 +190,152 @@
       }
   
       /**
  -	 * @see Collection#size()
  -	 */
  -	public int size()
  -	{
  -		if (isLoaded())
  -		{
  -			return getData().size();
  -		}
  -		else
  -		{
  -			if (m_size < 0)
  -			{
  -				loadSize();
  -			}
  -			return m_size;
  -		}
  -	}
  -
  -	/**
  -	 * @see Collection#isEmpty()
  -	 */
  -	public boolean isEmpty()
  -	{
  -		return size() == 0;
  -	}
  -
  -	/**
  -	 * @see Collection#contains(Object)
  -	 */
  -	public boolean contains(Object o)
  -	{
  -		return getData().contains(o);
  -	}
  -
  -	/**
  -	 * @see Collection#iterator()
  -	 */
  -	public Iterator iterator()
  -	{
  -		return getData().iterator();
  -	}
  -
  -	/**
  -	 * @see Collection#toArray()
  -	 */
  -	public Object[] toArray()
  -	{
  -		return getData().toArray();
  -	}
  -
  -	/**
  -	 * @see Collection#toArray(Object[])
  -	 */
  -	public Object[] toArray(Object[] a)
  -	{
  -		return getData().toArray(a);
  -	}
  -
  -	/**
  -	 * @see Collection#add(Object)
  -	 */
  -	public boolean add(Object o)
  -	{
  -		return getData().add(o);
  -	}
  -
  -	/**
  -	 * @see Collection#remove(Object)
  -	 */
  -	public boolean remove(Object o)
  -	{
  -		return getData().remove(o);
  -	}
  -
  -	/**
  -	 * @see Collection#containsAll(Collection)
  -	 */
  -	public boolean containsAll(Collection c)
  -	{
  -		return getData().containsAll(c);
  -	}
  -
  -	/**
  -	 * @see Collection#addAll(Collection)
  -	 */
  -	public boolean addAll(Collection c)
  -	{
  -		return getData().addAll(c);
  -	}
  -
  -	/**
  -	 * @see Collection#removeAll(Collection)
  -	 */
  -	public boolean removeAll(Collection c)
  -	{
  -		return getData().removeAll(c);
  -	}
  -
  -	/**
  -	 * @see Collection#retainAll(Collection)
  -	 */
  -	public boolean retainAll(Collection c)
  -	{
  -		return getData().retainAll(c);
  -	}
  +     * @see Collection#size()
  +     */
  +    public int size()
  +    {
  +        if (isLoaded())
  +        {
  +            return getData().size();
  +        }
  +        else
  +        {
  +            if (m_size < 0)
  +            {
  +                loadSize();
  +            }
  +            return m_size;
  +        }
  +    }
  +
  +    /**
  +     * @see Collection#isEmpty()
  +     */
  +    public boolean isEmpty()
  +    {
  +        return size() == 0;
  +    }
  +
  +    /**
  +     * @see Collection#contains(Object)
  +     */
  +    public boolean contains(Object o)
  +    {
  +        return getData().contains(o);
  +    }
  +
  +    /**
  +     * @see Collection#iterator()
  +     */
  +    public Iterator iterator()
  +    {
  +        return getData().iterator();
  +    }
  +
  +    /**
  +     * @see Collection#toArray()
  +     */
  +    public Object[] toArray()
  +    {
  +        return getData().toArray();
  +    }
   
  -	/**
  +    /**
  +     * @see Collection#toArray(Object[])
  +     */
  +    public Object[] toArray(Object[] a)
  +    {
  +        return getData().toArray(a);
  +    }
  +
  +    /**
  +     * @see Collection#add(Object)
  +     */
  +    public boolean add(Object o)
  +    {
  +        return getData().add(o);
  +    }
  +
  +    /**
  +     * @see Collection#remove(Object)
  +     */
  +    public boolean remove(Object o)
  +    {
  +        return getData().remove(o);
  +    }
  +
  +    /**
  +     * @see Collection#containsAll(Collection)
  +     */
  +    public boolean containsAll(Collection c)
  +    {
  +        return getData().containsAll(c);
  +    }
  +
  +    /**
  +     * @see Collection#addAll(Collection)
  +     */
  +    public boolean addAll(Collection c)
  +    {
  +        return getData().addAll(c);
  +    }
  +
  +    /**
  +     * @see Collection#removeAll(Collection)
  +     */
  +    public boolean removeAll(Collection c)
  +    {
  +        return getData().removeAll(c);
  +    }
  +
  +    /**
  +     * @see Collection#retainAll(Collection)
  +     */
  +    public boolean retainAll(Collection c)
  +    {
  +        return getData().retainAll(c);
  +    }
  +
  +    /**
        * Clear the proxy. A cleared proxy is defined as loaded
        *
  -	 * @see Collection#clear()
  -	 */
  -	public void clear()
  -	{
  -		Collection coll;
  -
  -        // BRJ: use an empty collection so isLoaded will return true
  -		try
  -		{
  -			coll = (Collection) getCollectionClass().newInstance();
  -		}
  -		catch (Exception e)
  -		{
  -			coll = new ArrayList();
  -		}
  +     * @see Collection#clear()
  +     */
  +    public void clear()
  +    {
  +        Collection coll;
  +
  +// BRJ: use an empty collection so isLoaded will return true
  +        try
  +        {
  +            coll = (Collection) getCollectionClass().newInstance();
  +        }
  +        catch (Exception e)
  +        {
  +            coll = new ArrayList();
  +        }
           setData(coll);
           m_size = 0;
   
  -	}
  +    }
   
  -	/**
  -	 * Gets the query.
  -	 * @return Returns a Query
  -	 */
  -	protected Query getQuery()
  -	{
  -		return m_query;
  -	}
  -
  -	/**
  -	 * Sets the query.
  -	 * @param query The query to set
  -	 */
  -	protected void setQuery(Query query)
  -	{
  -		this.m_query = query;
  -	}
  +    /**
  +     * Gets the query.
  +     * @return Returns a Query
  +     */
  +    protected Query getQuery()
  +    {
  +        return m_query;
  +    }
  +
  +    /**
  +     * Sets the query.
  +     * @param query The query to set
  +     */
  +    protected void setQuery(Query query)
  +    {
  +        this.m_query = query;
  +    }
   
   
       /**
  @@ -352,143 +353,138 @@
           {
               needsClose = false;
               m_broker.close();
  -        	m_broker = null;
  +            m_broker = null;
           }
       }
   
  -	/**
  -	 * Gets the broker.
  -	 * If no BrokerKey is available return the Default Broker.
  -	 * @return a PersistenceBroker
  -	 */
  -	protected synchronized PersistenceBroker getBroker() throws PBFactoryException
  -	{
  -        PersistenceBroker currentBroker;
  -
  -        // first try to use the current broker to avoid blocking
  -        if (getBrokerKey() != null)
  +    /**
  +     * Gets the broker.
  +     * If no PBKey is available a runtime exception will be thrown.
  +     * @return a PersistenceBroker
  +     */
  +    protected synchronized PersistenceBroker getBroker() throws PBFactoryException
  +    {
  +        PersistenceBroker broker;
  +        if (getBrokerKey() == null)
           {
  -            currentBroker = PersistenceBrokerThreadMapping.currentPersistenceBroker(getBrokerKey());
  +            /*
  +            arminw:
  +            if no PBKey is set we throw an exception, because we don't
  +            know which PB (connection) should be used.
  +            */
  +            throw new OJBRuntimeException("Can't find associated PBKey. Need PBKey to obtain
a valid" +
  +                    "PersistenceBroker instance from intern resources.");
           }
  -        else
  +        // first try to use the current threaded broker to avoid blocking
  +        broker = PersistenceBrokerThreadMapping.currentPersistenceBroker(getBrokerKey());
  +        // current broker not found, create a intern new one
  +        if(broker == null)
           {
  -            currentBroker = PersistenceBrokerThreadMapping.currentDefaultPersistenceBroker();
  +            if (m_broker == null)
  +            {
  +                m_broker = PersistenceBrokerFactory.createPersistenceBroker(getBrokerKey());
  +                // TODO: Better way?
  +                needsClose = true;
  +                broker = m_broker;
  +            }
           }
  -        if (currentBroker != null)
  +        return broker;
  +    }
  +
  +    /**
  +     * Gets the data, load it if not already done.
  +     * @return Returns a Collection
  +     */
  +    public synchronized Collection getData()
  +    {
  +        if (!isLoaded())
           {
  -            return currentBroker;
  +            setData(loadData());
           }
   
  -        // the current broker not found, create a new one
  -	    if (m_broker == null)
  -	    {
  -	    	if (getBrokerKey() != null)
  -	    	{
  -				m_broker = PersistenceBrokerFactory.createPersistenceBroker(getBrokerKey());
  -	    	}
  -	    	else
  -	    	{
  -				m_broker = PersistenceBrokerFactory.defaultPersistenceBroker();
  -	    	}
  -            // TODO: Better way?
  -            needsClose = true;
  -	    }
  -		return m_broker;
  -	}
  -
  -	/**
  -	 * Gets the data, load it if not already done.
  -	 * @return Returns a Collection
  -	 */
  -	public synchronized Collection getData()
  -	{
  -		if (!isLoaded())
  -		{
  -			setData(loadData());
  -		}
  -
  -		return m_data;
  -	}
  -
  -	/**
  -	 * Sets the data.
  -	 * @param data The data to set
  -	 */
  -	protected void setData(Collection data)
  -	{
  -		this.m_data = data;
  -	}
  -
  -	/**
  -	 * Gets the collectionClass.
  -	 * @return Returns a Class
  -	 */
  -	protected Class getCollectionClass()
  -	{
  -		return m_collectionClass;
  -	}
  -
  -	/**
  -	 * Sets the collectionClass.
  -	 * @param collectionClass The collectionClass to set
  -	 */
  -	protected void setCollectionClass(Class collectionClass)
  -	{
  -		this.m_collectionClass = collectionClass;
  -	}
  -
  -	/**
  -	 * @see ManageableCollection#ojbAdd(Object)
  -	 */
  -	public void ojbAdd(Object anObject)
  -	{
  -		add(anObject);
  -	}
  -
  -	/**
  -	 * @see ManageableCollection#ojbAddAll(ManageableCollection)
  -	 */
  -	public void ojbAddAll(ManageableCollection otherCollection)
  -	{
  -		addAll((CollectionProxy) otherCollection);
  -	}
  -
  -	/**
  -	 * @see ManageableCollection#ojbIterator()
  -	 */
  -	public Iterator ojbIterator()
  -	{
  -		return iterator();
  -	}
  +        return m_data;
  +    }
  +
  +    /**
  +     * Sets the data.
  +     * @param data The data to set
  +     */
  +    protected void setData(Collection data)
  +    {
  +        this.m_data = data;
  +    }
  +
  +    /**
  +     * Gets the collectionClass.
  +     * @return Returns a Class
  +     */
  +    protected Class getCollectionClass()
  +    {
  +        return m_collectionClass;
  +    }
  +
  +    /**
  +     * Sets the collectionClass.
  +     * @param collectionClass The collectionClass to set
  +     */
  +    protected void setCollectionClass(Class collectionClass)
  +    {
  +        this.m_collectionClass = collectionClass;
  +    }
  +
  +    /**
  +     * @see ManageableCollection#ojbAdd(Object)
  +     */
  +    public void ojbAdd(Object anObject)
  +    {
  +        add(anObject);
  +    }
  +
  +    /**
  +     * @see ManageableCollection#ojbAddAll(ManageableCollection)
  +     */
  +    public void ojbAddAll(ManageableCollection otherCollection)
  +    {
  +        addAll((CollectionProxy) otherCollection);
  +    }
  +
  +    /**
  +     * @see ManageableCollection#ojbIterator()
  +     */
  +    public Iterator ojbIterator()
  +    {
  +        return iterator();
  +    }
  +
       /**
        * @see org.apache.ojb.broker.ManageableCollection#afterStore(PersistenceBroker broker)
        */
       public void afterStore(PersistenceBroker broker) throws PersistenceBrokerException
       {
  -    	// If the real subject is a ManageableCollection
  -    	// the afterStore() callback must be invoked !
  +        // If the real subject is a ManageableCollection
  +        // the afterStore() callback must be invoked !
           Collection c = getData();
           if (c instanceof ManageableCollection)
  -             ((ManageableCollection) c).afterStore(broker);
  +            ((ManageableCollection) c).afterStore(broker);
  +    }
  +
  +    /**
  +     * Returns the brokerKey.
  +     * @return PBKey
  +     */
  +    protected PBKey getBrokerKey()
  +    {
  +        return m_brokerKey;
       }
   
       /**
  -	 * Returns the brokerKey.
  -	 * @return PBKey
  -	 */
  -	protected PBKey getBrokerKey()
  -	{
  -		return m_brokerKey;
  -	}
  -
  -	/**
  -	 * Sets the brokerKey.
  -	 * @param brokerKey The brokerKey to set
  -	 */
  -	protected void setBrokerKey(PBKey brokerKey)
  -	{
  -		this.m_brokerKey = brokerKey;
  -	}
  +     * Sets the brokerKey.
  +     * @param brokerKey The brokerKey to set
  +     */
  +    protected void setBrokerKey(PBKey brokerKey)
  +    {
  +        this.m_brokerKey = brokerKey;
  +    }
   
       public synchronized void addListener(CollectionProxyListener l)
       {
  
  
  

---------------------------------------------------------------------
To unsubscribe, e-mail: ojb-dev-unsubscribe@db.apache.org
For additional commands, e-mail: ojb-dev-help@db.apache.org


Mime
View raw message