chore: update quarkus version to 1.7.2.Final

knative · Sep 8, 2020 · 565066e · 565066e
1 parent 609ab86
commit 565066e
Show file tree

Hide file tree

Showing 5 changed files with 43 additions and 39 deletions.
diff --git a/pkged.go b/pkged.go
diff --git a/templates/quarkus/events/pom.xml b/templates/quarkus/events/pom.xml
@@ -12,10 +12,10 @@
     <maven.compiler.target>1.8</maven.compiler.target>
     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
     <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
-    <quarkus-plugin.version>1.5.0.Final</quarkus-plugin.version>
+    <quarkus-plugin.version>1.7.2.Final</quarkus-plugin.version>
     <quarkus.platform.artifact-id>quarkus-bom</quarkus.platform.artifact-id>
     <quarkus.platform.group-id>io.quarkus</quarkus.platform.group-id>
-    <quarkus.platform.version>1.5.0.Final</quarkus.platform.version>
+    <quarkus.platform.version>1.7.2.Final</quarkus.platform.version>
     <surefire-plugin.version>2.22.1</surefire-plugin.version>
   </properties>
   <dependencyManagement>

diff --git a/templates/quarkus/events/src/main/java/org/funqy/demo/GreetingFunctions.java b/templates/quarkus/events/src/main/java/org/funqy/demo/GreetingFunctions.java
@@ -1,6 +1,7 @@
 package org.funqy.demo;
 
 import io.quarkus.funqy.Funq;
+import io.smallrye.mutiny.Uni;
 import org.jboss.logging.Logger;
 
 import javax.inject.Inject;
@@ -15,23 +16,24 @@ public class GreetingFunctions {
     GreetingService service;
 
     @Funq
-    public CompletionStage<Greeting> greet(Identity name) {
-        CompletableFuture<Greeting> result = new CompletableFuture<>();
-        executor.schedule(()-> {
-            try {
-                log.info("*** In greeting service ***");
-                String message = service.hello(name.getName());
-                log.info("Sending back: " + message);
-                Greeting greeting = new Greeting();
-                greeting.setMessage(message);
-                greeting.setName(name.getName());
-                result.complete(greeting);
-
-            } catch (Throwable t) {
-                result.completeExceptionally(t);
-            }
-        }, 100, TimeUnit.MILLISECONDS);
-        return result;
+    public Uni<Greeting> greet(Identity name) {
+        return Uni.createFrom().emitter(uniEmitter -> {
+            executor.schedule(()-> {
+                try {
+                    log.info("*** In greeting service ***");
+                    String message = service.hello(name.getName());
+                    log.info("Sending back: " + message);
+                    Greeting greeting = new Greeting();
+                    greeting.setMessage(message);
+                    greeting.setName(name.getName());
+                    uniEmitter.complete(greeting);
+
+                } catch (Throwable t) {
+                    uniEmitter.fail(t);
+                }
+            }, 100, TimeUnit.MILLISECONDS);
+        });
+
     }
 
 }
diff --git a/templates/quarkus/http/pom.xml b/templates/quarkus/http/pom.xml
@@ -12,10 +12,10 @@
     <maven.compiler.target>1.8</maven.compiler.target>
     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
     <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
-    <quarkus-plugin.version>1.5.0.Final</quarkus-plugin.version>
+    <quarkus-plugin.version>1.7.2.Final</quarkus-plugin.version>
     <quarkus.platform.artifact-id>quarkus-bom</quarkus.platform.artifact-id>
     <quarkus.platform.group-id>io.quarkus</quarkus.platform.group-id>
-    <quarkus.platform.version>1.5.0.Final</quarkus.platform.version>
+    <quarkus.platform.version>1.7.2.Final</quarkus.platform.version>
     <surefire-plugin.version>2.22.1</surefire-plugin.version>
   </properties>
   <dependencyManagement>

diff --git a/templates/quarkus/http/src/main/java/org/funqy/demo/GreetingFunctions.java b/templates/quarkus/http/src/main/java/org/funqy/demo/GreetingFunctions.java
@@ -1,6 +1,7 @@
 package org.funqy.demo;
 
 import io.quarkus.funqy.Funq;
+import io.smallrye.mutiny.Uni;
 import org.jboss.logging.Logger;
 
 import javax.inject.Inject;
@@ -15,23 +16,24 @@ public class GreetingFunctions {
     GreetingService service;
 
     @Funq
-    public CompletionStage<Greeting> greet(Identity name) {
-        CompletableFuture<Greeting> result = new CompletableFuture<>();
-        executor.schedule(()-> {
-            try {
-                log.info("*** In greeting service ***");
-                String message = service.hello(name.getName());
-                log.info("Sending back: " + message);
-                Greeting greeting = new Greeting();
-                greeting.setMessage(message);
-                greeting.setName(name.getName());
-                result.complete(greeting);
-
-            } catch (Throwable t) {
-                result.completeExceptionally(t);
-            }
-        }, 100, TimeUnit.MILLISECONDS);
-        return result;
+    public Uni<Greeting> greet(Identity name) {
+        return Uni.createFrom().emitter(uniEmitter -> {
+            executor.schedule(()-> {
+                try {
+                    log.info("*** In greeting service ***");
+                    String message = service.hello(name.getName());
+                    log.info("Sending back: " + message);
+                    Greeting greeting = new Greeting();
+                    greeting.setMessage(message);
+                    greeting.setName(name.getName());
+                    uniEmitter.complete(greeting);
+
+                } catch (Throwable t) {
+                    uniEmitter.fail(t);
+                }
+            }, 100, TimeUnit.MILLISECONDS);
+        });
+
     }
 
 }