1 22 package org.jboss.test.asynch; 23 24 import junit.framework.Test; 25 import junit.framework.TestSuite; 26 import org.jboss.aspects.asynch.AsynchProvider; 27 import org.jboss.aspects.asynch.Future; 28 import org.jboss.test.JBossTestCase; 29 import org.jboss.test.aop.test.AOPTestSetup; 30 31 32 38 public class AsynchTestCase 39 extends JBossTestCase 40 { 41 org.jboss.logging.Logger log = getLog(); 42 43 static boolean deployed = false; 44 static int test = 0; 45 46 public AsynchTestCase(String name) 47 { 48 49 super(name); 50 51 } 52 53 public void testRemote() throws Exception 54 { 55 try 56 { 57 POJO pojo = (POJO) getInitialContext().lookup("pojo"); 58 59 AsynchProvider asynch = (AsynchProvider) pojo; 60 pojo.testMethod(5); 61 62 Future future = asynch.getFuture(); 63 int rtn = (Integer ) future.get(); 64 assertEquals(rtn, 5); 65 66 pojo.testMethod("hello"); 67 68 future = asynch.getFuture(); 69 String srtn = (String ) future.get(); 70 assertEquals("hello", srtn); 71 } 72 catch (Exception e) 73 { 74 throw new RuntimeException (e); 75 } 76 77 } 78 79 public void testLocal() throws Exception 80 { 81 POJO pojo = (POJO) getInitialContext().lookup("pojo"); 82 83 pojo.test(); 84 } 85 86 public void testCollocated() throws Exception 87 { 88 POJO pojo = (POJO) getInitialContext().lookup("pojo"); 89 90 pojo.testCollocated(); 91 } 92 93 public static Test suite() throws Exception 94 { 95 TestSuite suite = new TestSuite(); 96 suite.addTest(new TestSuite(AsynchTestCase.class)); 97 98 AOPTestSetup setup = new AOPTestSetup(suite, "asynch-test.sar"); 99 return setup; 100 } 101 102 } 103 | Popular Tags |