InitialContext ctx1 = new InitialContext(env1);
SessionToEntityHome home1 =
(SessionToEntityHome) ctx1.lookup("cif.StatefulSession");
AComplexPK key = new AComplexPK(true, 0, 0, 0, "testCacheInvalidation");
SessionToEntity bean1 = home1.create(key);
String msg = bean1.createEntity();
log.info("create#1, "+msg);
// Call accessEntity twice to validate data is consistent on both nodes
NodeAnswer answer1 = bean1.accessEntity();
log.info("Answer1: "+answer1);
NodeAnswer answer2 = bean1.accessEntity();
log.info("Answer2: "+answer2);
assertTrue("accessCount == 2", bean1.getAccessCount() == 2);
assertFalse("answer1.nodeId != answer2.nodeId",
answer1.nodeId.equals(answer2.nodeId));
// Call validateAccessCount twice to validate data is consistent on both nodes
answer1 = bean1.validateAccessCount(2);
log.info(answer1);
answer2 = bean1.validateAccessCount(2);
log.info(answer2);
assertFalse("answer1.nodeId != answer2.nodeId",
answer1.nodeId.equals(answer2.nodeId));
bean1.remove();
}