Package org.jboss.cache

Examples of org.jboss.cache.Region.takeLastEventNode()


      MethodCall mc = MethodCallFactory.create(MethodDeclarations.putKeyValMethodLocal_id,
            null, fqn, key, value, false);
      interceptor.invoke(InvocationContext.fromMethodCall(mc));
      assertEquals("value", cache.peek(fqn, false, false).getDirect(key));
      EvictedEventNode event = region.takeLastEventNode();
      assertEquals(NodeEventType.ADD_ELEMENT_EVENT, event.getEventType());
      assertEquals(1, event.getElementDifference());
      assertEquals(fqn, event.getFqn());
      assertEquals("value", cache.peek(fqn, false, false).getDirect(key));
      assertNull(region.takeLastEventNode());
View Full Code Here


      EvictedEventNode event = region.takeLastEventNode();
      assertEquals(NodeEventType.ADD_ELEMENT_EVENT, event.getEventType());
      assertEquals(1, event.getElementDifference());
      assertEquals(fqn, event.getFqn());
      assertEquals("value", cache.peek(fqn, false, false).getDirect(key));
      assertNull(region.takeLastEventNode());

      mc = MethodCallFactory.create(MethodDeclarations.putKeyValMethodLocal_id,
            null, fqn, key, value, false);
      interceptor.invoke(InvocationContext.fromMethodCall(mc));
      assertEquals("value", cache.peek(fqn, false, false).getDirect(key));
View Full Code Here

      mc = MethodCallFactory.create(MethodDeclarations.putKeyValMethodLocal_id,
            null, fqn, key, value, false);
      interceptor.invoke(InvocationContext.fromMethodCall(mc));
      assertEquals("value", cache.peek(fqn, false, false).getDirect(key));
      event = region.takeLastEventNode();
      assertEquals(NodeEventType.ADD_ELEMENT_EVENT, event.getEventType());
      assertEquals(1, event.getElementDifference());
      assertEquals(fqn, event.getFqn());
      assertEquals("value", cache.peek(fqn, false, false).getDirect(key));
      assertNull(region.takeLastEventNode());
View Full Code Here

      event = region.takeLastEventNode();
      assertEquals(NodeEventType.ADD_ELEMENT_EVENT, event.getEventType());
      assertEquals(1, event.getElementDifference());
      assertEquals(fqn, event.getFqn());
      assertEquals("value", cache.peek(fqn, false, false).getDirect(key));
      assertNull(region.takeLastEventNode());

   }

   public void testRemoveNode() throws Throwable
   {
View Full Code Here

      MethodCall mc = MethodCallFactory.create(MethodDeclarations.removeDataMethodLocal_id, null, fqn, false);
      interceptor.invoke(InvocationContext.fromMethodCall(mc));

      assertEquals(0, cache.peek(fqn, false, false).getDataDirect().size());
      Region region = regionManager.getRegion(fqn.toString(), false);
      EvictedEventNode event = region.takeLastEventNode();
      assertEquals(NodeEventType.REMOVE_NODE_EVENT, event.getEventType());
      assertEquals(fqn, event.getFqn());
      assertNull(region.takeLastEventNode());

      mc = MethodCallFactory.create(MethodDeclarations.removeNodeMethodLocal_id, null, fqn, false, false);
View Full Code Here

      assertEquals(0, cache.peek(fqn, false, false).getDataDirect().size());
      Region region = regionManager.getRegion(fqn.toString(), false);
      EvictedEventNode event = region.takeLastEventNode();
      assertEquals(NodeEventType.REMOVE_NODE_EVENT, event.getEventType());
      assertEquals(fqn, event.getFqn());
      assertNull(region.takeLastEventNode());

      mc = MethodCallFactory.create(MethodDeclarations.removeNodeMethodLocal_id, null, fqn, false, false);
      interceptor.invoke(InvocationContext.fromMethodCall(mc));

      assertNull(cache.peek(fqn, false, false));
View Full Code Here

      mc = MethodCallFactory.create(MethodDeclarations.removeNodeMethodLocal_id, null, fqn, false, false);
      interceptor.invoke(InvocationContext.fromMethodCall(mc));

      assertNull(cache.peek(fqn, false, false));
      event = region.takeLastEventNode();
      assertEquals(NodeEventType.REMOVE_NODE_EVENT, event.getEventType());
      assertEquals(fqn, event.getFqn());
      assertNull(region.takeLastEventNode());
   }
View Full Code Here

      assertNull(cache.peek(fqn, false, false));
      event = region.takeLastEventNode();
      assertEquals(NodeEventType.REMOVE_NODE_EVENT, event.getEventType());
      assertEquals(fqn, event.getFqn());
      assertNull(region.takeLastEventNode());
   }

   public void testRemoveElement() throws Throwable
   {
      Fqn fqn = Fqn.fromString("/a/b/c");
View Full Code Here

            null, fqn, "a", false);
      interceptor.invoke(InvocationContext.fromMethodCall(mc));

      assertNull(cache.get(fqn, "a"));
      Region region = regionManager.getRegion(fqn.toString(), false);
      EvictedEventNode event = region.takeLastEventNode();
      assertEquals(NodeEventType.REMOVE_ELEMENT_EVENT, event.getEventType());
      assertEquals(fqn, event.getFqn());
      assertEquals(1, event.getElementDifference());
      assertNull(region.takeLastEventNode());
View Full Code Here

      Region region = regionManager.getRegion(fqn.toString(), false);
      EvictedEventNode event = region.takeLastEventNode();
      assertEquals(NodeEventType.REMOVE_ELEMENT_EVENT, event.getEventType());
      assertEquals(fqn, event.getFqn());
      assertEquals(1, event.getElementDifference());
      assertNull(region.takeLastEventNode());

      mc = MethodCallFactory.create(MethodDeclarations.removeKeyMethodLocal_id,
            null, fqn, "b", false);
      interceptor.invoke(InvocationContext.fromMethodCall(mc));
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.