Package org.jboss.cache.aop.test

Examples of org.jboss.cache.aop.test.Person


            }
           
            log.info("Cache A details:\n" + cacheA.printDetails());
           
            // Compare cache contents
            Person p1 = null;
            Person p2 = null;
            for (int i = 0; i < count; i++)
            {
               log.info("Cache " + names[i] + " details:\n" +
                        stressors[i].getTreeCache().printDetails());
              
               for (int j = 0; j < SUBTREE_SIZE; j++)
               {
                 
                  String fqn = "/" + names[i] +"/" + j;
                  log.info("TEST: Getting A:" + fqn);
                  p1 = (Person) cacheA.getObject(fqn);
                  boolean p1Null = p1 == null;
                  log.info("TEST: Getting " + names[i] + ":" + fqn);
                  p2 = (Person) stressors[i].getTreeCache().getObject(fqn);
                  boolean p2Null = p2 == null;
                  assertEquals("Run " + x + ": " + fqn +
                               " null status matches", p1Null, p2Null);
                  if (!p1Null)
                  {
                     assertEquals("Run " + x + ": A:" + fqn + " age matches " + names[i] + ":" + fqn,
                                  p1.getAge(), p2.getAge());
                     assertEquals("Run " + x + ": A:" + fqn + " name matches " + names[i] + ":" + fqn,
                                  p1.getName(), p2.getName());
                     assertEquals("Run " + x + ": A:" + fqn + " address matches " + names[i] + ":" + fqn,
                                  p1.getAddress().getStreet(),
                                  p2.getAddress().getStreet());
                  }
               }
            }
         }
        
View Full Code Here


      addr2 = new Address();
      addr2.setStreet("222 Happy Dr");
      addr2.setCity("Fremont");
      addr2.setZip(22222);
     
      joe = new Person();
      joe.setName("Joe");
      joe.setAge(TWENTY.intValue());
      joe.setAddress(addr1);
      Set skills = new HashSet();
      skills.add("TENNIS");
      skills.add("CARPENTRY");
      joe.setSkills(skills);

      jane = new Person();
      jane.setName("Jane");
      jane.setAge(TWENTYFIVE.intValue());
      jane.setAddress(addr1);
      skills = new HashSet();
      skills.add("JUJITSU");
      skills.add("MACRAME");
      jane.setSkills(skills);

      bob = new Person();
      bob.setName("Bob");
      bob.setAge(FORTY.intValue());
      bob.setAddress(addr2);
      skills = new HashSet();
      skills.add("LANGUAGES");
      skills.add("LAWN BOWLING");
      bob.setSkills(skills);

      jill = new Person();
      jill.setName("Jill");
      jill.setAge(TWENTYFIVE.intValue());
      jill.setAddress(addr2);
      skills = new HashSet();
      skills.add("FORTRAN");
View Full Code Here


   public void testDynamicRefSwapping() throws Exception
   {
      tester.createPerson("/person/test3", "Joe", 32);
      Person person = (Person)tester.getPerson("/person/test3");
      try {
         person.setAge(30);
         List med = person.getMedication();
         assertNull("Medication should be null ", med);
         person.setAge(61);
         med = person.getMedication();
         assertEquals("Medication ", (Object)"Lipitor", (Object)med.get(0));
         assertEquals("Medication on cache1 ", (Object)"Lipitor",
               (Object)((Person)tester1.getPerson("/person/test3")).getMedication().get(0));

         person.setAge(71);
         assertEquals("Medication ", (Object)"Vioxx", (Object)med.get(1));
         assertEquals("Medication on cache1 ", (Object)"Vioxx",
               (Object)((Person)tester1.getPerson("/person/test3")).getMedication().get(1));

      } catch (Exception e) {
View Full Code Here

   }

   public void testBadFqn() throws Exception
   {
      log_.info("testBadFqn() ....");
      Person test = new Person();
      test.setName("Ben");
      test.setAge(10);
      cache_.putObject("/a", test);
      Person result = (Person)cache_.getObject("/a");
      assertEquals(" ", test, result);
      result.setAge(20);

      try {
         cache_.putObject(InternalDelegate.JBOSS_INTERNAL, test);
         fail("putObject under JBoss_Internal should fail");
      } catch (IllegalArgumentException iex)
View Full Code Here

   }

   public void testPutRemove() throws Exception
   {
      log_.info("testPutRemove() ....");
      Person test = new Person();
      test.setName("Ben");
      test.setAge(10);
      cache_.putObject("/a", test);
      Person result = (Person)cache_.getObject("/a");
      assertEquals(" ", test, result);
      result.setAge(20);
      cache_.removeObject("/a");
      assertNull("Object should be null ", cache_.getObject("/a"));
      assertEquals("Age should be updated as ", 20, test.getAge());
   }
View Full Code Here

   }

   public void testPutRemoveNodeExistence() throws Exception
   {
      log_.info("testPutRemove() ....");
      Person test = new Person();
      test.setName("Ben");
      test.setAge(10);
      cache_.putObject("/a", test);
      Person result = (Person)cache_.getObject("/a");
      assertEquals(" ", test, result);
      result.setAge(20);
      cache_.removeObject("/a");
      assertNull("Object should be null ", cache_.getObject("/a"));
      assertEquals("Age should be updated as ", 20, test.getAge());

      assertNull("DataNode should not exisit ", cache_.get("/a"));
View Full Code Here

   public void testFindObjects() throws Exception
   {
      log_.info("testFindObjects() ....");
      Map map = cache_.findObjects("/");
      assertEquals("Objects size should be ", 0, map.size());
      Person ben = new Person();
      ben.setName("Ben");
      ben.setAge(10);
      cache_.putObject("/a/b/c", ben);
      cache_.putObject("/e", ben); // multiple keys, same pojo
      Person joe = new Person();
      joe.setName("Joe");
      joe.setAge(10);
      cache_.putObject("/f/joe", joe);
      map = cache_.findObjects("/");
      assertEquals("Objects size should be ", 3, map.size());

      map = cache_.findObjects("/a");
View Full Code Here

      {
         cache.activateRegion("/a/b");
         log.info("TEST: " + name + " activated region" + " " + System.currentTimeMillis());
         String childFqn = "/a/b/" + name;
        
         Person p = new Person();
         p.setName("Person " + name);
        
         Address addr = new Address();        
         addr.setStreet(name + " Test Street");
         addr.setCity(name + ", CA");
         p.setAddress(addr);
        
         TestingUtil.sleepThread(1);
        
//         tm.begin();
//         try
View Full Code Here

        
         Person[] people = new Person[SUBTREE_SIZE];
         boolean[] loaded = new boolean[SUBTREE_SIZE];
         for (int j = 0; j < SUBTREE_SIZE; j++)
         {
            Person p = new Person();
            p.setName("Person " + j);
            p.setAge(j);
            p.setAddress((j % 2 == 0) ? addr1 : addr2);
            people[j] = p;
         }
        
         boolean acquired = true;
         try
View Full Code Here

   public void testMap() throws Exception
   {
      log.info("testMap() ....");
      tester.createPerson("/person/test1", "Ben Wang", 40);
      assertEquals((Object) "Ben Wang", (Object) tester.getName("/person/test1"));
      Person ben = (Person)tester.getPerson("/person/test1");
//      Map skills = new HashMap();
      Map hobbies = ben.getHobbies();
      if (hobbies == null) {
         hobbies = new HashMap();
         ben.setHobbies(hobbies);
         // NB: it is neccessary to get hobbies again to get advised version
         hobbies = ben.getHobbies();
      }
      hobbies.put("1", "English");
      hobbies.put("2", "French");
      if( !(hobbies instanceof ClassProxy)) {
         fail("Hobbies is not an instance of ClassProxy");
      }
//      ben.setHobbies(skills);
//      skills = ben.getHobbies();

      hobbies = ben.getHobbies();
      assertEquals("Hobbies size", 2, hobbies.size());
      log.debug("Hobbies is " + hobbies.toString());
   }
View Full Code Here

TOP

Related Classes of org.jboss.cache.aop.test.Person

Copyright © 2018 www.massapicom. 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.