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

[Manik Surtani]

  User: msurtani
  Date: 07/06/08 11:03:06

  Modified:    src/org/jboss/cache/notifications  Notifier.java
  Log:
  Temp patch to make sure all notifications go thru the Notification Interceptor
  
  Revision  Changes    Path
  1.26      +6 -1      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.25
  retrieving revision 1.26
  diff -u -b -r1.25 -r1.26
  --- Notifier.java	1 Jun 2007 15:08:09 -0000	1.25
  +++ Notifier.java	8 Jun 2007 15:03:06 -0000	1.26
  @@ -154,7 +154,7 @@
       */
      public void notifyNodeCreated(Fqn fqn, boolean pre, InvocationContext ctx, boolean sendImmediately)
      {
  -
  +      sendImmediately = false;
         boolean originLocal = ctx.isOriginLocal();
         if (sendImmediately)
         {
  @@ -194,6 +194,7 @@
       */
      public void notifyNodeModified(Fqn fqn, boolean pre, CacheListener.ModificationType modificationType, Map<K, V> data, InvocationContext ctx, boolean sendImmediately)
      {
  +      sendImmediately = false;
         boolean originLocal = ctx.isOriginLocal();
         Map dataCopy = copy(data);
         if (sendImmediately)
  @@ -233,6 +234,7 @@
       */
      public void notifyNodeRemoved(Fqn fqn, boolean pre, Map<K, V> data, InvocationContext ctx, boolean sendImmediately)
      {
  +      sendImmediately = false;
         boolean originLocal = ctx.isOriginLocal();
         Map dataCopy = copy(data);
         if (sendImmediately)
  @@ -272,6 +274,7 @@
       */
      public void notifyNodeVisited(Fqn fqn, boolean pre, InvocationContext ctx, boolean sendImmediately)
      {
  +      sendImmediately = false;
         if (sendImmediately)
         {
            if (hasListenersOrEvictionListener)
  @@ -301,6 +304,7 @@
   
      public void notifyNodeMoved(Fqn originalFqn, Fqn newFqn, boolean pre, InvocationContext ctx, boolean sendImmediately)
      {
  +      sendImmediately = false;
         boolean originLocal = ctx.isOriginLocal();
         if (sendImmediately)
         {
  @@ -630,6 +634,7 @@
         InvocationContext backup = resetInvocationContext(ctx);
         for (MethodCall c : queue)
         {
  +         if (log.isTraceEnabled()) log.trace("Invoking queued notification " + c);
            if (evictionPolicyListener != null)
            {
               try