ISPN-16317 Fix Reactive tutorial

infinispan · Jul 26, 2024 · 73fcbfc · 73fcbfc
1 parent 022696e
commit 73fcbfc
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...tive-api/src/main/java/org/infinispan/tutorial/simple/reactive/InfinispanReactiveApi.java b/...tive-api/src/main/java/org/infinispan/tutorial/simple/reactive/InfinispanReactiveApi.java
@@ -53,6 +53,8 @@ static void manipulateCacheReactive() {
               .onItem().delayIt().onExecutor(executor).by(Duration.ofSeconds(1))
               .invoke(v -> System.out.printf("%s -- %s\n", LocalDateTime.now(), v))
               .await().atMost(Duration.ofSeconds(2));
+
+      executor.shutdown();
    }
 
    public static final void connect() {
@@ -77,7 +79,7 @@ public static final void connect() {
          try {
             TutorialsConnectorHelper.startInfinispanContainer();
             builder = createHotRodConfigurationBuilder();
-            builder.addServer().host(HOST).port(INFINISPAN_CONTAINER.getFirstMappedPort());
+            builder.addServer().host(HOST).port(INFINISPAN_CONTAINER.getMappedPort(SINGLE_PORT));
             infinispan = Infinispan.create(builder.build());
             clearCache();
          } catch (Exception ex) {