Package org.jboss.cache

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

37
38
39
40
41
42
43
44
45
46
47
      region.putNodeEvent(new EvictedEventNode(fqn1, NodeEventType.ADD_NODE_EVENT));
      region.putNodeEvent(new EvictedEventNode(fqn2, NodeEventType.ADD_NODE_EVENT));
      region.putNodeEvent(new EvictedEventNode(fqn3, NodeEventType.ADD_NODE_EVENT));

      assertEquals("AddedNode queue size ", 3, region.nodeEventQueueSize());
      EvictedEventNode node = region.takeLastEventNode();
      Fqn fqn = node.getFqn();
      assertEquals("DataNode retrieved should be FILO ", fqn, fqn1);
      assertEquals("AddedNode queue size ", 2, region.nodeEventQueueSize());
      fqn = region.takeLastEventNode().getFqn();
      fqn = region.takeLastEventNode().getFqn();
View Full Code Here
41
42
43
44
45
46
47
48
49
50
51
      assertEquals("AddedNode queue size ", 3, region.nodeEventQueueSize());
      EvictedEventNode node = region.takeLastEventNode();
      Fqn fqn = node.getFqn();
      assertEquals("DataNode retrieved should be FILO ", fqn, fqn1);
      assertEquals("AddedNode queue size ", 2, region.nodeEventQueueSize());
      fqn = region.takeLastEventNode().getFqn();
      fqn = region.takeLastEventNode().getFqn();
      node = region.takeLastEventNode();
      assertNull("DataNode should be null", node);
   }
View Full Code Here
42
43
44
45
46
47
48
49
50
51
52
      EvictedEventNode node = region.takeLastEventNode();
      Fqn fqn = node.getFqn();
      assertEquals("DataNode retrieved should be FILO ", fqn, fqn1);
      assertEquals("AddedNode queue size ", 2, region.nodeEventQueueSize());
      fqn = region.takeLastEventNode().getFqn();
      fqn = region.takeLastEventNode().getFqn();
      node = region.takeLastEventNode();
      assertNull("DataNode should be null", node);
   }

   public void testEventQueue()
View Full Code Here
43
44
45
46
47
48
49
50
51
52
53
      Fqn fqn = node.getFqn();
      assertEquals("DataNode retrieved should be FILO ", fqn, fqn1);
      assertEquals("AddedNode queue size ", 2, region.nodeEventQueueSize());
      fqn = region.takeLastEventNode().getFqn();
      fqn = region.takeLastEventNode().getFqn();
      node = region.takeLastEventNode();
      assertNull("DataNode should be null", node);
   }

   public void testEventQueue()
   {
View Full Code Here
59
60
61
62
63
64
65
66
67
68
69
      region.putNodeEvent(new EvictedEventNode(fqn1, NodeEventType.REMOVE_NODE_EVENT));
      region.putNodeEvent(new EvictedEventNode(fqn2, NodeEventType.ADD_NODE_EVENT));
      region.putNodeEvent(new EvictedEventNode(fqn3, NodeEventType.VISIT_NODE_EVENT));

      assertEquals("RemovedNode queue size ", 3, region.nodeEventQueueSize());
      NodeEventType event = region.takeLastEventNode().getEventType();
      assertEquals("DataNode retrieved should be: ", NodeEventType.REMOVE_NODE_EVENT, event);
      region.takeLastEventNode();
      region.takeLastEventNode();
      EvictedEventNode node = region.takeLastEventNode();
      assertNull("DataNode should be null", node);
View Full Code Here
61
62
63
64
65
66
67
68
69
70
71
      region.putNodeEvent(new EvictedEventNode(fqn3, NodeEventType.VISIT_NODE_EVENT));

      assertEquals("RemovedNode queue size ", 3, region.nodeEventQueueSize());
      NodeEventType event = region.takeLastEventNode().getEventType();
      assertEquals("DataNode retrieved should be: ", NodeEventType.REMOVE_NODE_EVENT, event);
      region.takeLastEventNode();
      region.takeLastEventNode();
      EvictedEventNode node = region.takeLastEventNode();
      assertNull("DataNode should be null", node);
   }
View Full Code Here
62
63
64
65
66
67
68
69
70
71
72
      assertEquals("RemovedNode queue size ", 3, region.nodeEventQueueSize());
      NodeEventType event = region.takeLastEventNode().getEventType();
      assertEquals("DataNode retrieved should be: ", NodeEventType.REMOVE_NODE_EVENT, event);
      region.takeLastEventNode();
      region.takeLastEventNode();
      EvictedEventNode node = region.takeLastEventNode();
      assertNull("DataNode should be null", node);
   }

   public void testMassivePutOnQueue()
View Full Code Here
63
64
65
66
67
68
69
70
71
72
73
      assertEquals("RemovedNode queue size ", 3, region.nodeEventQueueSize());
      NodeEventType event = region.takeLastEventNode().getEventType();
      assertEquals("DataNode retrieved should be: ", NodeEventType.REMOVE_NODE_EVENT, event);
      region.takeLastEventNode();
      region.takeLastEventNode();
      EvictedEventNode node = region.takeLastEventNode();
      assertNull("DataNode should be null", node);
   }

   public void testMassivePutOnQueue()
   {
View Full Code Here
95
96
97
98
99
100
101
102
103
104
105
      MethodCall mc = MethodCallFactory.create(MethodDeclarations.getNodeMethodLocal_id,
            Fqn.fromString(fqn1));
      interceptor.invoke(InvocationContext.fromMethodCall(mc));
      Region regionABC = regionManager.getRegion(fqn1, false);
      assertNull(regionABC.takeLastEventNode());

      putQuietly(fqn1, "key", "value");
      NodeSPI<Object, Object> node = cast(cache.peek(Fqn.fromString(fqn1), false, false));
      assertNotNull(node);
      assertEquals("value", node.getDirect("key"));
View Full Code Here
113
114
115
116
117
118
119
120
121
122
123
      mc = MethodCallFactory.create(MethodDeclarations.getNodeMethodLocal_id,
            Fqn.fromString(fqn1));
      interceptor.invoke(InvocationContext.fromMethodCall(mc));

      regionABC = regionManager.getRegion(fqn1, false);
      EvictedEventNode event = regionABC.takeLastEventNode();
      assertEquals(NodeEventType.VISIT_NODE_EVENT, event.getEventType());
      assertEquals(fqn1, event.getFqn().toString());
      assertNull(regionABC.takeLastEventNode());

      mc = MethodCallFactory.create(MethodDeclarations.getNodeMethodLocal_id,
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.