dubbo-notifications mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From liu...@apache.org
Subject [incubator-dubbo-samples] branch 3.x updated: add $asyncInvoke() sample
Date Fri, 10 May 2019 05:56:16 GMT
This is an automated email from the ASF dual-hosted git repository.

liujun pushed a commit to branch 3.x
in repository https://gitbox.apache.org/repos/asf/incubator-dubbo-samples.git


The following commit(s) were added to refs/heads/3.x by this push:
     new 5a8e979  add $asyncInvoke() sample
5a8e979 is described below

commit 5a8e979d91a5f030af4370d7a832791ac5e85b23
Author: ken.lj <ken.lj.hz@gmail.com>
AuthorDate: Fri May 10 13:56:04 2019 +0800

    add $asyncInvoke() sample
---
 .../samples/generic/call/GenericCallConsumer.java  | 28 +++++++++++++++++++---
 1 file changed, 25 insertions(+), 3 deletions(-)

diff --git a/dubbo-samples-generic/dubbo-samples-generic-call/dubbo-samples-generic-call-consumer/src/main/java/org/apache/dubbo/samples/generic/call/GenericCallConsumer.java
b/dubbo-samples-generic/dubbo-samples-generic-call/dubbo-samples-generic-call-consumer/src/main/java/org/apache/dubbo/samples/generic/call/GenericCallConsumer.java
index c2be8c9..4ee98eb 100644
--- a/dubbo-samples-generic/dubbo-samples-generic-call/dubbo-samples-generic-call-consumer/src/main/java/org/apache/dubbo/samples/generic/call/GenericCallConsumer.java
+++ b/dubbo-samples-generic/dubbo-samples-generic-call/dubbo-samples-generic-call-consumer/src/main/java/org/apache/dubbo/samples/generic/call/GenericCallConsumer.java
@@ -41,12 +41,14 @@ public class GenericCallConsumer {
         applicationConfig.setRegistry(registryConfig);
         referenceConfig.setApplication(applicationConfig);
         referenceConfig.setGeneric(true);
-//        referenceConfig.setAsync(true);
+        referenceConfig.setAsync(true);
         referenceConfig.setTimeout(7000);
 
         genericService = referenceConfig.get();
-        $invokeWithNormalSignature();
-        $invokeWithAsyncSignature();
+//        $invokeWithNormalSignature();
+//        $invokeWithAsyncSignature();
+        $invokeAsyncWithAsyncSignature();
+        $invokeAsyncWithNormalSignature();
         System.in.read();
     }
 
@@ -72,4 +74,24 @@ public class GenericCallConsumer {
         System.out.println("...." + result);
     }
 
+    public static void $invokeAsyncWithAsyncSignature() throws Exception {
+        CompletableFuture<Object> future  = genericService.$invokeAsync("sayHelloAsync",
new String[]{"java.lang.String"}, new Object[]{"world"});
+
+        future.whenComplete((value, t) -> {
+            System.err.println(value);
+        });
+
+        System.out.println(".... before return ...");
+    }
+
+    public static void $invokeAsyncWithNormalSignature() throws Exception {
+        CompletableFuture<Object> future  = genericService.$invokeAsync("sayHello",
new String[]{"java.lang.String"}, new Object[]{"world"});
+
+        future.whenComplete((value, t) -> {
+            System.err.println(value);
+        });
+
+        System.out.println(".... before return ...");
+    }
+
 }


---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@dubbo.apache.org
For additional commands, e-mail: notifications-help@dubbo.apache.org


Mime
View raw message