Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  package org.infinispan.api.tree;
  
 
 import static org.testng.AssertJUnit.assertEquals;
 import static org.testng.AssertJUnit.assertNull;
 
 
 
 @Test(groups = "functional", testName = "api.tree.NodeReplicatedMoveTest")
 
    static final Fqn A = Fqn.fromString("/a"), B = Fqn.fromString("/b"), C = Fqn.fromString("/c"), D = Fqn.fromString("/d"), E = Fqn.fromString("/e");
    static final Object k = "key"vA = "valueA"vB = "valueB"vC = "valueC"vD = "valueD"vE = "valueE";
 
 
    protected void createCacheManagers() throws Throwable {
       cb.invocationBatching().enable();
 
       createClusteredCaches(2, "replSync"cb);
 
       Cache c1 = cache(0, "replSync");
       Cache c2 = cache(1, "replSync");
 
        = TestingUtil.getTransactionManager(c1);
 
        = new TreeCacheImpl<ObjectObject>(c1);
        = new TreeCacheImpl<ObjectObject>(c2);
    }
 
    public void testReplicatability() {
       Node<ObjectObjectrootNode = .getRoot();
 
       Node<ObjectObjectnodeA = rootNode.addChild();
       Node<ObjectObjectnodeB = nodeA.addChild();
 
       nodeA.put();
       nodeB.put();
 
       assertEquals(.getRoot().getChild().get());
 
       assertEquals(.getRoot().getChild().get());
 
       // now move...
       .move(nodeB.getFqn(), .);
 
       assertEquals(.getRoot().getChild().get());
       assertEquals(.getRoot().getChild().get());
 
       assertEquals(.getRoot().getChild().get());
       assertEquals(.getRoot().getChild().get());
    }
 
    public void testReplTxCommit() throws Exception {
       Node<ObjectObjectrootNode = .getRoot();
       Fqn A_B = Fqn.fromRelativeFqn();
       Node<ObjectObjectnodeA = rootNode.addChild();
       Node<ObjectObjectnodeB = nodeA.addChild();
 
       nodeA.put();
       nodeB.put();
 
       assertEquals(.getRoot().getChild().get());
 
       assertEquals(.getRoot().getChild().get());
 
       // now move...
       .begin();
       .move(nodeB.getFqn(), .);
 
       assertEquals(.get());
       assertNull(.get(A_B));
       assertEquals(.get());
       .commit();
 
       assertEquals(.getRoot().getChild().get());
       assertEquals(.getRoot().getChild().get());
       assertEquals(.getRoot().getChild().get());
       assertEquals(.getRoot().getChild().get());
 
    }
   public void testReplTxRollback() throws Exception {
      ..println(TreeStructureSupport.printTree(true));
      Node<ObjectObjectrootNode = .getRoot();
      Node<ObjectObjectnodeA = rootNode.addChild();
      Node<ObjectObjectnodeB = nodeA.addChild();
      nodeA.put();
      nodeB.put();
      ..println(TreeStructureSupport.printTree(true));
      // now move...
      .begin();
      .move(nodeB.getFqn(), .);
      assertEquals(.get());
      assertEquals(.get());
      .rollback();
      ..println(TreeStructureSupport.printTree(true));
   }
New to GrepCode? Check out our FAQ X