Package org.infinispan

Examples of org.infinispan.Cache.removeListener()

143
144
145
146
147
148
149
150
151
152
153
         if (throwError && cause.getCause() instanceof InvocationTargetException)
            throw cause.getCause().getCause();
         else
            throw cause.getCause();
      } finally {
         cache2.removeListener(listener);
      }
   }

   @Listener
   public static class ErrorInducingListener {
View Full Code Here
407
408
409
410
411
412
413
414
415
416
417
         cache1.put("key", pojo);
         assert l.newValue instanceof Pojo : "recieved " + l.newValue.getClass().getName();
         // +1 due to new marshallable checks
         assertSerializationCounts(2, 0);
      } finally {
         cache1.removeListener(l);
      }
   }

   public void testRemoteCallbackValues() throws Exception {
      Cache cache1 = cache(0, "replSync");
View Full Code Here
424
425
426
427
428
429
430
431
432
433
434
         pojo.b = false;
         cache1.put("key", pojo);
         assert l.newValue instanceof Pojo;
         assertSerializationCounts(1, 1);
      } finally {
         cache2.removeListener(l);
      }
   }
  
   public void testEvictWithMarshalledValueKey() {
      Cache cache1 = cache(0, "replSync");
View Full Code Here
137
138
139
140
141
142
143
144
145
146
147
         if (throwError && e.getCause() instanceof InvocationTargetException)
            throw e.getCause().getCause();
         else
            throw e.getCause();
      } finally {
         cache2.removeListener(listener);
      }
   }

   @Listener
   public static class ErrorInducingListener {
View Full Code Here
407
408
409
410
411
412
413
414
415
416
417
         cache1.put("key", pojo);
         assert l.newValue instanceof Pojo : "recieved " + l.newValue.getClass().getName();
         // +1 due to new marshallable checks
         assertSerializationCounts(2, 0);
      } finally {
         cache1.removeListener(l);
      }
   }

   public void testRemoteCallbackValues() throws Exception {
      Cache cache1 = cache(0, "replSync");
View Full Code Here
424
425
426
427
428
429
430
431
432
433
434
         pojo.b = false;
         cache1.put("key", pojo);
         assert l.newValue instanceof Pojo;
         assertSerializationCounts(1, 1);
      } finally {
         cache2.removeListener(l);
      }
   }
  
   public void testEvictWithMarshalledValueKey() {
      Cache cache1 = cache(0, "replSync");
View Full Code Here
388
389
390
391
392
393
394
395
396
397
398
         Pojo pojo = new Pojo();
         cache1.put("key", pojo);
         assertTrue("recieved " + l.newValue.getClass().getName(), l.newValue instanceof Pojo);
         assertSerializationCounts(1, 0);
      } finally {
         cache1.removeListener(l);
      }
   }

   public void testRemoteCallbackValues() throws Exception {
      Cache cache1 = cache(0, "replSync");
View Full Code Here
405
406
407
408
409
410
411
412
413
414
415
         pojo.b = false;
         cache1.put("key", pojo);
         assertTrue(l.newValue instanceof Pojo);
         assertSerializationCounts(1, 1);
      } finally {
         cache2.removeListener(l);
      }
   }

   public void testEvictWithMarshalledValueKey() {
      Cache cache1 = cache(0, "replSync");
View Full Code Here
407
408
409
410
411
412
413
414
415
416
417
         cache1.put("key", pojo);
         assert l.newValue instanceof Pojo : "recieved " + l.newValue.getClass().getName();
         // +1 due to new marshallable checks
         assertSerializationCounts(2, 0);
      } finally {
         cache1.removeListener(l);
      }
   }

   public void testRemoteCallbackValues() throws Exception {
      Cache cache1 = cache(0, "replSync");
View Full Code Here
424
425
426
427
428
429
430
431
432
433
434
         pojo.b = false;
         cache1.put("key", pojo);
         assert l.newValue instanceof Pojo;
         assertSerializationCounts(1, 1);
      } finally {
         cache2.removeListener(l);
      }
   }
  
   public void testEvictWithMarshalledValueKey() {
      Cache cache1 = cache(0, "replSync");
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.