TUSCANY-3784 - Add multiple operations and a void return type to the async part of the implementation same

git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@1059033 13f79535-47bb-0310-9956-ffa450edef68

5 files changed, 91 insertions, 4 deletions

diff --git a/sca-java-2.x/trunk/samples/extending-tuscany/implementation-sample/src/test/java/sample/Upper.java b/sca-java-2.x/trunk/samples/extending-tuscany/implementation-sample/src/test/java/sample/Upper.java
index 9c772b3487..3a831a0ecf 100644
--- a/sca-java-2.x/trunk/samples/extending-tuscany/implementation-sample/src/test/java/sample/Upper.java
+++ b/sca-java-2.x/trunk/samples/extending-tuscany/implementation-sample/src/test/java/sample/Upper.java
@@ -30,4 +30,8 @@ import org.oasisopen.sca.annotation.Remotable;
 public interface Upper {
 
     String upper(String s);
+    
+    String upper2(String s);
+    
+    String upperVoid(String s);
 }
diff --git a/sca-java-2.x/trunk/samples/extending-tuscany/implementation-sample/src/test/java/sample/UpperSampleAsyncReferenceImpl.java b/sca-java-2.x/trunk/samples/extending-tuscany/implementation-sample/src/test/java/sample/UpperSampleAsyncReferenceImpl.java
index 7a86d68043..4bfc8356c4 100644
--- a/sca-java-2.x/trunk/samples/extending-tuscany/implementation-sample/src/test/java/sample/UpperSampleAsyncReferenceImpl.java
+++ b/sca-java-2.x/trunk/samples/extending-tuscany/implementation-sample/src/test/java/sample/UpperSampleAsyncReferenceImpl.java
@@ -46,6 +46,8 @@ public class UpperSampleAsyncReferenceImpl {
     WSDLReference upper;
     
     Element response;
+    Element response2;
+    public static String responseVoid;
     CountDownLatch latch = new CountDownLatch( 1 );
     
     public String upper(String s) {
@@ -80,4 +82,51 @@ public class UpperSampleAsyncReferenceImpl {
         this.response = response;
         latch.countDown();
     }
+    
+    public String upper2(String s) {
+        out.println("UpperSampleAsyncReferenceImpl.upper2(" + s + ")");
+        
+        // TODO - I'm passing in the non-wrapped version of the parameter
+        //        here which doesn't seem right. Need to test that databinding
+        //        wraps it correctly
+        //final Element ureq = xdom("http://sample/upper-async", "s", text(s));
+        NodeBuilder node1 = elem("s", text(s));
+        final Element ureq = xdom("http://sample/upper-async", "upper", node1);
+        upper.callAsync("upper2", ureq);
+        
+        try {
+            Thread.sleep(500);
+            latch.await(500, TimeUnit.SECONDS);
+        } catch (Exception ex) {
+            // do nothing
+        }
+        
+        if( response2 != null ) return response2.getTextContent();
+        else return "upper did not get called back";
+    }
+    
+    /**
+     *  In this implementation the convention is that the 
+     *  async callback arrives at an operation named
+     *  operationName + Callback
+     */
+    public void upper2Callback(Element response) {
+        out.println("UpperSampleAsyncReferenceImpl.upper2Callback(" + response.getTextContent() + ")");
+        this.response2 = response;
+        latch.countDown();
+    }    
+    
+    public String upperVoid(String s) {
+        out.println("UpperSampleAsyncReferenceImpl.upperVoid(" + s + ")");
+        
+        // TODO - I'm passing in the non-wrapped version of the parameter
+        //        here which doesn't seem right. Need to test that databinding
+        //        wraps it correctly
+        //final Element ureq = xdom("http://sample/upper-async", "s", text(s));
+        NodeBuilder node1 = elem("s", text(s));
+        final Element ureq = xdom("http://sample/upper-async", "upper", node1);
+        upper.callAsync("upperVoid", ureq);
+        return responseVoid;
+    }
+    
 }
diff --git a/sca-java-2.x/trunk/samples/extending-tuscany/implementation-sample/src/test/java/sample/UpperSampleAsyncServiceImpl.java b/sca-java-2.x/trunk/samples/extending-tuscany/implementation-sample/src/test/java/sample/UpperSampleAsyncServiceImpl.java
index 69d6cb9ecf..75fe271d7a 100644
--- a/sca-java-2.x/trunk/samples/extending-tuscany/implementation-sample/src/test/java/sample/UpperSampleAsyncServiceImpl.java
+++ b/sca-java-2.x/trunk/samples/extending-tuscany/implementation-sample/src/test/java/sample/UpperSampleAsyncServiceImpl.java
@@ -38,8 +38,15 @@ public class UpperSampleAsyncServiceImpl {
 
     public Element call(String op, Element e) {
         String input = e.getTextContent();
-        out.println("UpperSampleAsyncServiceImpl.upper(" + input + ")");
+        out.println("UpperSampleAsyncServiceImpl." + op + "(" + input + ")");
         String output = input.toUpperCase();
-        return xdom("http://sample/upper-async", "upperResponse", elem("result", text(output)));
+        
+        if (!op.equals("upperVoid")){
+            return xdom("http://sample/upper-async", "upperResponse", elem("result", text(output)));
+        } else {
+            out.println("No response as void return type");
+            UpperSampleAsyncReferenceImpl.responseVoid = output;
+            return null;
+        }
     }
 }
diff --git a/sca-java-2.x/trunk/samples/extending-tuscany/implementation-sample/src/test/java/sample/UpperTest.java b/sca-java-2.x/trunk/samples/extending-tuscany/implementation-sample/src/test/java/sample/UpperTest.java
index 5399e4410d..f1daf8155e 100644
--- a/sca-java-2.x/trunk/samples/extending-tuscany/implementation-sample/src/test/java/sample/UpperTest.java
+++ b/sca-java-2.x/trunk/samples/extending-tuscany/implementation-sample/src/test/java/sample/UpperTest.java
@@ -34,4 +34,13 @@ public class UpperTest {
         out.println("UpperTest.upper(" + s + ")");
         return s.toUpperCase();
     }
+    
+    public String upper2(String s) {
+        out.println("UpperTest.upper2(" + s + ")");
+        return s.toUpperCase();
+    }
+    
+    public void upperVoid(String s) {
+        out.println("UpperTest.upperVoid(" + s + ")");
+    }
 }
diff --git a/sca-java-2.x/trunk/samples/extending-tuscany/implementation-sample/src/test/java/sample/impl/SampleNativeAsyncTestCase.java b/sca-java-2.x/trunk/samples/extending-tuscany/implementation-sample/src/test/java/sample/impl/SampleNativeAsyncTestCase.java
index f5198e7df0..28d54647c5 100644
--- a/sca-java-2.x/trunk/samples/extending-tuscany/implementation-sample/src/test/java/sample/impl/SampleNativeAsyncTestCase.java
+++ b/sca-java-2.x/trunk/samples/extending-tuscany/implementation-sample/src/test/java/sample/impl/SampleNativeAsyncTestCase.java
@@ -54,11 +54,29 @@ public class SampleNativeAsyncTestCase {
     }
 
     @Test
-    public void testReference() {
-        System.out.println("SampleNaiveAsyncTestCase.testReference");
+    public void testUpper() {
+        System.out.println("SampleNaiveAsyncTestCase.testUpper");
         Upper upper = node.getService(Upper.class, "SampleNativeAsyncReference");
         final String r = upper.upper("async"); 
         System.out.println(r);
         assertEquals("ASYNC", r);
     }
+    
+    @Test
+    public void testUpper2() {
+        System.out.println("SampleNaiveAsyncTestCase.testUpper2");
+        Upper upper = node.getService(Upper.class, "SampleNativeAsyncReference");
+        final String r = upper.upper2("async2"); 
+        System.out.println(r);
+        assertEquals("ASYNC2", r);
+    }   
+    
+    @Test
+    public void testVoid() {
+        System.out.println("SampleNaiveAsyncTestCase.testUpperVoid");
+        Upper upper = node.getService(Upper.class, "SampleNativeAsyncReference");
+        final String r = upper.upperVoid("asyncVoid");
+        System.out.println(r);
+        assertEquals("ASYNCVOID", r);
+    }    
 }