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

[Manik Surtani]

  User: msurtani
  Date: 07/01/03 10:33:09

  Modified:    src/org/jboss/cache/statetransfer 
                        DefaultStateTransferIntegrator.java
  Log:
  Improved notification mechanism, added a notification interceptor
  
  Revision  Changes    Path
  1.14      +6 -8      JBossCache/src/org/jboss/cache/statetransfer/DefaultStateTransferIntegrator.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: DefaultStateTransferIntegrator.java
  ===================================================================
  RCS file: /cvsroot/jboss/JBossCache/src/org/jboss/cache/statetransfer/DefaultStateTransferIntegrator.java,v
  retrieving revision 1.13
  retrieving revision 1.14
  diff -u -b -r1.13 -r1.14
  --- DefaultStateTransferIntegrator.java	3 Jan 2007 03:56:15 -0000	1.13
  +++ DefaultStateTransferIntegrator.java	3 Jan 2007 15:33:09 -0000	1.14
  @@ -14,7 +14,6 @@
   import org.jboss.cache.Node;
   import org.jboss.cache.NodeSPI;
   import org.jboss.cache.Region;
  -import org.jboss.cache.RegionManager;
   import org.jboss.cache.buddyreplication.BuddyManager;
   import org.jboss.cache.eviction.EvictedEventNode;
   import org.jboss.cache.eviction.NodeEventType;
  @@ -26,7 +25,6 @@
   import java.io.IOException;
   import java.io.ObjectInputStream;
   import java.util.HashSet;
  -import java.util.Iterator;
   import java.util.Map;
   import java.util.Set;
   
  @@ -193,8 +191,8 @@
      private void notifyAllNodesCreated(Node curr)
      {
         if (curr == null) return;
  -      getCache().getNotifier().notifyNodeCreated(curr.getFqn(), true);
  -      getCache().getNotifier().notifyNodeCreated(curr.getFqn(), false);
  +      getCache().getNotifier().notifyNodeCreated(curr.getFqn(), true, true);
  +      getCache().getNotifier().notifyNodeCreated(curr.getFqn(), false, true);
         Set<Node> children = curr.getChildren();
         for (Node n : children)
         {