[jboss-cvs] JBossCache/src/org/jboss/cache/notifications ...

[Manik Surtani]

  User: msurtani
  Date: 06/08/29 12:35:52

  Modified:    src/org/jboss/cache/notifications  Notifier.java
  Log:
  Fixed basic replication issues
  
  Revision  Changes    Path
  1.4       +353 -339  JBossCache/src/org/jboss/cache/notifications/Notifier.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: Notifier.java
  ===================================================================
  RCS file: /cvsroot/jboss/JBossCache/src/org/jboss/cache/notifications/Notifier.java,v
  retrieving revision 1.3
  retrieving revision 1.4
  diff -u -b -r1.3 -r1.4
  --- Notifier.java	22 Aug 2006 12:27:51 -0000	1.3
  +++ Notifier.java	29 Aug 2006 16:35:52 -0000	1.4
  @@ -7,13 +7,13 @@
   package org.jboss.cache.notifications;
   
   import EDU.oswego.cs.dl.util.concurrent.CopyOnWriteArraySet;
  +import org.apache.commons.logging.Log;
  +import org.apache.commons.logging.LogFactory;
   import org.jboss.cache.CacheListener;
   import org.jboss.cache.CacheSPI;
   import org.jboss.cache.Fqn;
   import org.jboss.cache.InvocationContext;
   import org.jgroups.View;
  -import org.apache.commons.logging.Log;
  -import org.apache.commons.logging.LogFactory;
   
   import java.util.Collections;
   import java.util.Map;
  @@ -50,6 +50,7 @@
   
       /**
        * Sets an eviction policy listener.
  +    *
        * @param l
        */
       public void setEvictionPolicyListener(CacheListener l)
  @@ -59,6 +60,7 @@
   
       /**
        * Adds a cache listener to the list of cache listeners registered.
  +    *
        * @param l
        */
       public void addCacheListener(CacheListener l)
  @@ -72,6 +74,7 @@
   
       /**
        * Removes a cache listener from the list of cache listeners registered.
  +    *
        * @param l
        */
       public void removeCacheListener(CacheListener l)
  @@ -102,6 +105,7 @@
   
       /**
        * Notifies all registered listeners of a nodeCreated event.
  +    *
        * @param fqn
        * @param pre
        */
  @@ -126,6 +130,7 @@
   
       /**
        * Notifies all registered listeners of a nodeModified event.
  +    *
        * @param fqn
        * @param pre
        * @param data
  @@ -150,6 +155,7 @@
   
       /**
        * Notifies all registered listeners of a nodeRemoved event.
  +    *
        * @param fqn
        * @param pre
        * @param data
  @@ -174,6 +180,7 @@
   
       /**
        * Notifies all registered listeners of a nodeVisited event.
  +    *
        * @param fqn
        * @param pre
        */
  @@ -196,6 +203,7 @@
   
       /**
        * Notifies all registered listeners of a nodeEvicted event.
  +    *
        * @param fqn
        * @param pre
        */
  @@ -219,6 +227,7 @@
   
       /**
        * Notifies all registered listeners of a nodeLoaded event.
  +    *
        * @param fqn
        * @param pre
        * @param data
  @@ -242,6 +251,7 @@
   
       /**
        * Notifies all registered listeners of a nodeActivated event.
  +    *
        * @param fqn
        * @param pre
        */
  @@ -264,6 +274,7 @@
   
       /**
        * Notifies all registered listeners of a nodePassivated event.
  +    *
        * @param fqn
        * @param pre
        */
  @@ -286,6 +297,7 @@
   
       /**
        * Notifies all registered listeners of a cacheStarted event.
  +    *
        * @param cache
        */
       public void notifyCacheStarted(CacheSPI cache)
  @@ -307,6 +319,7 @@
   
       /**
        * Notifies all registered listeners of a cacheStopped event.
  +    *
        * @param cache
        */
       public void notifyCacheStopped(CacheSPI cache)
  @@ -328,7 +341,7 @@
   
       private void restoreInvocationContext()
       {
  -        cache.setInvocationContext(tempCtx);
  +      cache.getInvocationContext().setState(tempCtx);
       }
   
       private void resetInvocationContext()
  @@ -346,6 +359,7 @@
   
       /**
        * Notifies all registered listeners of a viewChange event.
  +    *
        * @param new_view
        */
       public void notifyViewChange(View new_view)