KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > org > jboss > ejb3 > test > clusteredentity > unit > EntityUnitTestCase


1 /*
2   * JBoss, Home of Professional Open Source
3   * Copyright 2005, JBoss Inc., and individual contributors as indicated
4   * by the @authors tag. See the copyright.txt in the distribution for a
5   * full listing of individual contributors.
6   *
7   * This is free software; you can redistribute it and/or modify it
8   * under the terms of the GNU Lesser General Public License as
9   * published by the Free Software Foundation; either version 2.1 of
10   * the License, or (at your option) any later version.
11   *
12   * This software is distributed in the hope that it will be useful,
13   * but WITHOUT ANY WARRANTY; without even the implied warranty of
14   * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
15   * Lesser General Public License for more details.
16   *
17   * You should have received a copy of the GNU Lesser General Public
18   * License along with this software; if not, write to the Free
19   * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
20   * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
21   */
22 package org.jboss.ejb3.test.clusteredentity.unit;
23
24 import java.util.Properties JavaDoc;
25 import javax.naming.InitialContext JavaDoc;
26 import org.jboss.ejb3.test.clusteredentity.Customer;
27 import org.jboss.ejb3.test.clusteredentity.EntityTest;
28 import org.jboss.test.JBossClusteredTestCase;
29 import junit.framework.Test;
30
31 /**
32  * Sample client for the jboss container.
33  *
34  * @author <a HREF="mailto:bill@burkecentral.com">Bill Burke</a>
35  * @version $Id: EntityUnitTestCase.java 58110 2006-11-04 08:34:21Z scott.stark@jboss.org $
36  */
37
38 public class EntityUnitTestCase
39 extends JBossClusteredTestCase
40 {
41    org.jboss.logging.Logger log = getLog();
42
43    static boolean deployed = false;
44    static int test = 0;
45
46    public EntityUnitTestCase(String JavaDoc name)
47    {
48
49       super(name);
50
51    }
52    
53    public void testAll() throws Exception JavaDoc
54    {
55       System.out.println("*** testServerFound()");
56       String JavaDoc node0 = System.getProperty("jbosstest.cluster.node0");
57       String JavaDoc node1 = System.getProperty("jbosstest.cluster.node1");
58         
59       Properties JavaDoc prop0 = new Properties JavaDoc();
60       prop0.put("java.naming.factory.initial", "org.jnp.interfaces.NamingContextFactory");
61       prop0.put("java.naming.factory.url.pkgs", "org.jboss.naming:org.jnp.interfaces");
62       prop0.put("java.naming.provider.url", "jnp://" + node0 + ":1099");
63       
64       System.out.println("===== Node0 properties: ");
65       System.out.println(prop0);
66       
67       Properties JavaDoc prop1 = new Properties JavaDoc();
68       prop1.put("java.naming.factory.initial", "org.jnp.interfaces.NamingContextFactory");
69       prop1.put("java.naming.factory.url.pkgs", "org.jboss.naming:org.jnp.interfaces");
70       prop1.put("java.naming.provider.url", "jnp://" + node1 + ":1099");
71
72       System.out.println("===== Node1 properties: ");
73       System.out.println(prop1);
74
75       System.out.println("Lookup node 0");
76       InitialContext JavaDoc ctx0 = new InitialContext JavaDoc(prop0);
77       
78       System.out.println("Create node 0");
79       EntityTest tester0 = (EntityTest)ctx0.lookup("EntityTestBean/remote");
80       Customer customer = tester0.createCustomer();
81
82       //Call finder twice since Hibernate seems to not actually save collections
83 //into cache on persist(), so make sure it is put into cache on find.
84 System.out.println("Find node 0");
85       customer = tester0.findByCustomerId(customer.getId());
86       System.out.println("Find(2) node 0");
87       customer = tester0.findByCustomerId(customer.getId());
88
89       //Check everything was in cache
90 System.out.println("Check cache 0");
91       tester0.loadedFromCache();
92
93       //Now connect to cache on node2 and make sure it is all there
94 System.out.println("Lookup node 1");
95       InitialContext JavaDoc ctx1 = new InitialContext JavaDoc(prop1);
96       
97       EntityTest tester1 = (EntityTest)ctx1.lookup("EntityTestBean/remote");
98       System.out.println("Find node 1");
99       customer = tester1.findByCustomerId(customer.getId());
100
101       //Check everything was in cache
102 System.out.println("Check cache 1");
103       tester1.loadedFromCache();
104       
105    }
106
107    public static Test suite() throws Exception JavaDoc
108    {
109       return JBossClusteredTestCase.getDeploySetup(EntityUnitTestCase.class, "clusteredentity-test.jar");
110    }
111 }
112
Popular Tags