Package org.jboss.cache

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


      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.getKeyValueMethodLocal_id, fqn, key, false);
      interceptor.invoke(InvocationContext.fromMethodCall(mc));
      region = regionManager.getRegion(fqn.toString(), false);
      event = region.takeLastEventNode();
View Full Code Here


      assertNull(region.takeLastEventNode());

      mc = MethodCallFactory.create(MethodDeclarations.getKeyValueMethodLocal_id, fqn, key, false);
      interceptor.invoke(InvocationContext.fromMethodCall(mc));
      region = regionManager.getRegion(fqn.toString(), false);
      event = region.takeLastEventNode();
      assertEquals(NodeEventType.VISIT_NODE_EVENT, event.getEventType());
      assertEquals(fqn, event.getFqn());
      assertNull(region.takeLastEventNode());

      mc = MethodCallFactory.create(MethodDeclarations.removeKeyMethodLocal_id,
View Full Code Here

      interceptor.invoke(InvocationContext.fromMethodCall(mc));
      region = regionManager.getRegion(fqn.toString(), false);
      event = region.takeLastEventNode();
      assertEquals(NodeEventType.VISIT_NODE_EVENT, event.getEventType());
      assertEquals(fqn, event.getFqn());
      assertNull(region.takeLastEventNode());

      mc = MethodCallFactory.create(MethodDeclarations.removeKeyMethodLocal_id,
            null, fqn, key, false);
      interceptor.invoke(InvocationContext.fromMethodCall(mc));
View Full Code Here

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

      assertNull(cache.get(fqn, key));
      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

      assertNull(cache.get(fqn, key));
      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

      // We expect events for /a, /a/b and /a/b/c
      int nodeEventQueueSize = region.nodeEventQueueSize();
      int i = 0;
      while (region.nodeEventQueueSize() > 0)
      {
         System.out.println(++i + ") Queue contains : " + region.takeLastEventNode());
      }

      assertEquals("Saw the expected number of node events", 3, nodeEventQueueSize);
   }
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.