1 22 package org.jboss.test.testbeancluster.test; 23 24 import java.util.Properties ; 25 import javax.naming.Context ; 26 import javax.naming.InitialContext ; 27 28 import junit.framework.Test; 29 import junit.framework.TestSuite; 30 31 import org.jboss.test.JBossClusteredTestCase; 32 import org.jboss.test.testbean.interfaces.AComplexPK; 33 import org.jboss.test.testbeancluster.interfaces.SessionToEntityHome; 34 import org.jboss.test.testbeancluster.interfaces.SessionToEntity; 35 import org.jboss.test.testbeancluster.interfaces.NodeAnswer; 36 37 42 public class CacheInvalidationUnitTestCase extends JBossClusteredTestCase 43 { 44 public CacheInvalidationUnitTestCase(String name) 45 { 46 super(name); 47 } 48 49 public static Test suite() throws Exception 50 { 51 TestSuite suite = new TestSuite(); 52 Test t1 = getDeploySetup(CacheInvalidationUnitTestCase.class, 53 "test-cif.ear"); 54 55 suite.addTest(t1); 56 57 DBSetup wrapper = new DBSetup(suite); 59 return wrapper; 60 } 61 62 public void testCacheInvalidation() 63 throws Exception 64 { 65 log.info("+++ testCacheInvalidation"); 66 67 String [] urls = getNamingURLs(); 69 Properties env1 = new Properties (); 70 env1.setProperty(Context.INITIAL_CONTEXT_FACTORY, 71 "org.jnp.interfaces.NamingContextFactory"); 72 env1.setProperty(Context.PROVIDER_URL, urls[0]); 73 InitialContext ctx1 = new InitialContext (env1); 74 75 SessionToEntityHome home1 = 76 (SessionToEntityHome) ctx1.lookup("cif.StatefulSession"); 77 AComplexPK key = new AComplexPK(true, 0, 0, 0, "testCacheInvalidation"); 78 SessionToEntity bean1 = home1.create(key); 79 String msg = bean1.createEntity(); 80 log.info("create#1, "+msg); 81 NodeAnswer answer1 = bean1.accessEntity(); 83 log.info("Answer1: "+answer1); 84 NodeAnswer answer2 = bean1.accessEntity(); 85 log.info("Answer2: "+answer2); 86 assertTrue("accessCount == 2", bean1.getAccessCount() == 2); 87 assertTrue("answer1.nodeId != answer2.nodeId", 88 answer1.nodeId.equals(answer2.nodeId) == false); 89 90 answer1 = bean1.validateAccessCount(2); 92 log.info(answer1); 93 answer2 = bean1.validateAccessCount(2); 94 log.info(answer2); 95 assertTrue("answer1.nodeId != answer2.nodeId", 96 answer1.nodeId.equals(answer2.nodeId) == false); 97 bean1.remove(); 98 } 99 100 } 101 | Popular Tags |