Updated to use GF 2.0 (#13)

Co-authored-by: GitLab <naveena.dhougoda-hamal@diffusiondata.com>
diffusiondata · May 20, 2024 · 1e790cf · 1e790cf
1 parent 544cb59
commit 1e790cf
Show file tree

Hide file tree

Showing 4 changed files with 18 additions and 4 deletions.
diff --git a/...er/src/main/java/com/diffusiondata/example/adapter/human/HumanStreamingSourceHandler.java b/...er/src/main/java/com/diffusiondata/example/adapter/human/HumanStreamingSourceHandler.java
@@ -32,7 +32,19 @@ public HumanStreamingSourceHandler(
         this.gui = new HumanGui(
             greeting,
             this.stateHandler::getState,
-            ev -> this.stateHandler.reportStatus(ev.getStatus(), ev.getTitle(), ev.getDescription())
+            ev -> {
+                try {
+                    return
+                        this
+                            .stateHandler
+                            .reportStatus(ev.getStatus(), ev.getTitle(), ev.getDescription())
+                            .get(5000, TimeUnit.MILLISECONDS);
+                }
+                catch (InterruptedException | ExecutionException |
+                       TimeoutException ex) {
+                    throw new IllegalStateException(ex);
+                }
+            }
         );
         this.gui.addSendEventHandler((ev) -> {
             try {

diff --git a/misc/src/main/java/com/diffusiondata/gateway/example/ExampleGatewayApplication.java b/misc/src/main/java/com/diffusiondata/gateway/example/ExampleGatewayApplication.java
@@ -64,7 +64,8 @@ public void initialize(
     }
 
     @Override
-    public GatewayMeterRegistry getGatewayMeterRegistry() {
+    public GatewayMeterRegistry initializeGatewayMeterRegistry(
+        Map<String, Object> globalParams) {
         return () -> meterRegistry;
     }
 

diff --git a/pom.xml b/pom.xml
@@ -32,7 +32,7 @@
         <dependency>
             <groupId>com.diffusiondata.gateway</groupId>
             <artifactId>gateway-framework</artifactId>
-            <version>2.0.0_RC1</version>
+            <version>2.0.0</version>
         </dependency>
         <dependency>
             <groupId>io.micrometer</groupId>

diff --git a/sample-diffusion-adapter/src/main/java/diffusion/Application.java b/sample-diffusion-adapter/src/main/java/diffusion/Application.java
@@ -27,7 +27,8 @@ public class Application implements GatewayApplication {
         new JmxMeterRegistry(s -> null, Clock.SYSTEM);
 
     @Override
-    public GatewayMeterRegistry getGatewayMeterRegistry() {
+    public GatewayMeterRegistry initializeGatewayMeterRegistry(
+        Map<String, Object> globalParams) {
         return () -> meterRegistry;
     }