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

[Vladmir Blagojevic]

  User: vblagojevic
  Date: 07/07/23 11:45:51

  Modified:    src/org/jboss/cache/loader  AbstractCacheLoader.java
  Log:
  added check for NodeDataExceptionMarker
  
  Revision  Changes    Path
  1.28      +6 -0      JBossCache/src/org/jboss/cache/loader/AbstractCacheLoader.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: AbstractCacheLoader.java
  ===================================================================
  RCS file: /cvsroot/jboss/JBossCache/src/org/jboss/cache/loader/AbstractCacheLoader.java,v
  retrieving revision 1.27
  retrieving revision 1.28
  diff -u -b -r1.27 -r1.28
  --- AbstractCacheLoader.java	17 Jul 2007 17:22:13 -0000	1.27
  +++ AbstractCacheLoader.java	23 Jul 2007 15:45:51 -0000	1.28
  @@ -92,6 +92,12 @@
            // no persistent state sent across; return?
            return;
         }
  +      if (objectFromStream instanceof NodeDataExceptionMarker){
  +    	  NodeDataExceptionMarker ndem = (NodeDataExceptionMarker) objectFromStream;
  +    	  throw new CacheException("State provider cacheloader at node " + ndem.getCacheNodeIdentity()
  +                                   + " threw exception during loadState (see Caused by)", ndem.getCause());  
  +      }
  +      
         List nodeData = (List) objectFromStream;
   
         //for (nd = (NodeData) in.readObject(); nd != null && !nd.isMarker(); nd = (NodeData) in.readObject())