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

[Manik Surtani]

  User: msurtani
  Date: 07/05/30 07:35:15

  Modified:    src/org/jboss/cache/notifications  Notifier.java
  Log:
  JBCACHE-1073
  
  Revision  Changes    Path
  1.24      +10 -6     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.23
  retrieving revision 1.24
  diff -u -b -r1.23 -r1.24
  --- Notifier.java	29 May 2007 16:25:20 -0000	1.23
  +++ Notifier.java	30 May 2007 11:35:15 -0000	1.24
  @@ -409,11 +409,13 @@
       *
       * @param fqn
       * @param pre
  +    * @param data
       * @param ctx             context of invocation
       * @param sendImmediately whether notifications are deferred to the NotificationInterceptor (sendImmediately = false)
       */
  -   public void notifyNodeActivated(Fqn fqn, boolean pre, InvocationContext ctx, boolean sendImmediately)
  +   public void notifyNodeActivated(Fqn fqn, boolean pre, Map<K, V> data, InvocationContext ctx, boolean sendImmediately)
      {
  +      Map<K, V> dataCopy = copy(data);
         if (sendImmediately)
         {
            if (hasListenersOrEvictionListener)
  @@ -421,13 +423,13 @@
               InvocationContext backup = resetInvocationContext(ctx);
               if (evictionPolicyListener != null)
               {
  -               evictionPolicyListener.nodeActivated(fqn, pre);
  +               evictionPolicyListener.nodeActivated(fqn, pre, (Map<Object, Object>) dataCopy);
               }
               if (hasListeners)
               {
                  for (CacheListener listener : listeners)
                  {
  -                  listener.nodeActivated(fqn, pre);
  +                  listener.nodeActivated(fqn, pre, (Map<Object, Object>) dataCopy);
                  }
               }
               restoreInvocationContext(backup);
  @@ -445,11 +447,13 @@
       *
       * @param fqn
       * @param pre
  +    * @param data
       * @param ctx             context of invocation
       * @param sendImmediately whether notifications are deferred to the NotificationInterceptor (sendImmediately = false)
       */
  -   public void notifyNodePassivated(Fqn fqn, boolean pre, InvocationContext ctx, boolean sendImmediately)
  +   public void notifyNodePassivated(Fqn fqn, boolean pre, Map<K, V> data, InvocationContext ctx, boolean sendImmediately)
      {
  +      Map<K, V> dataCopy = copy(data);
         if (sendImmediately)
         {
            if (hasListenersOrEvictionListener)
  @@ -457,13 +461,13 @@
               InvocationContext backup = resetInvocationContext(ctx);
               if (evictionPolicyListener != null)
               {
  -               evictionPolicyListener.nodePassivated(fqn, pre);
  +               evictionPolicyListener.nodePassivated(fqn, pre, (Map<Object, Object>) dataCopy);
               }
               if (hasListeners)
               {
                  for (CacheListener listener : listeners)
                  {
  -                  listener.nodePassivated(fqn, pre);
  +                  listener.nodePassivated(fqn, pre, (Map<Object, Object>) dataCopy);
                  }
               }
               restoreInvocationContext(backup);