added reproducer for quarkusio/quarkus#35966

sdaschner · Sep 18, 2023 · 0688781 · 0688781
1 parent fc2ba37
commit 0688781
Show file tree

Hide file tree

Showing 5 changed files with 18 additions and 60 deletions.
diff --git a/client/pom.xml b/client/pom.xml
@@ -22,29 +22,17 @@
             <groupId>io.quarkus</groupId>
             <artifactId>quarkus-picocli</artifactId>
         </dependency>
+
+<!--        <dependency>-->
+<!--            <groupId>io.quarkus</groupId>-->
+<!--            <artifactId>quarkus-rest-client-reactive-jsonb</artifactId>-->
+<!--        </dependency>-->
+<!-- when switching to classic, the issue with https://github.com/quarkusio/quarkus/issues/35966 goes away -->
         <dependency>
             <groupId>io.quarkus</groupId>
             <artifactId>quarkus-rest-client-jsonb</artifactId>
         </dependency>
 
-        <dependency>
-            <groupId>org.junit.jupiter</groupId>
-            <artifactId>junit-jupiter</artifactId>
-            <version>5.7.2</version>
-            <scope>test</scope>
-        </dependency>
-        <dependency>
-            <groupId>org.mockito</groupId>
-            <artifactId>mockito-core</artifactId>
-            <version>3.11.2</version>
-            <scope>test</scope>
-        </dependency>
-        <dependency>
-            <groupId>org.assertj</groupId>
-            <artifactId>assertj-core</artifactId>
-            <version>3.20.2</version>
-            <scope>test</scope>
-        </dependency>
     </dependencies>
 
     <build>

diff --git a/client/src/main/java/com/sebastian_daschner/client/DummyUpdatesResource.java b/client/src/main/java/com/sebastian_daschner/client/DummyUpdatesResource.java
@@ -14,7 +14,7 @@
 @Path("updates")
 @Produces(MediaType.SERVER_SENT_EVENTS)
 //
-// this class is required due to https://github.com/quarkusio/quarkus/issues/35967
+// this class is required due to https://github.com/quarkusio/quarkus/issues/35967 (only when quarkus-rest-client-jsonb is used, not for -reactive)
 // if this class gets removed, the SSE client connection stops working
 public class DummyUpdatesResource {
 

diff --git a/client/src/main/java/com/sebastian_daschner/client/SseClient.java b/client/src/main/java/com/sebastian_daschner/client/SseClient.java
@@ -34,8 +34,8 @@ public void someMethod() {
         WebTarget target = client.target("http://localhost:8080/updates");
         updateSource = SseEventSource.target(target).build();
         updateSource.register(ev -> {
-            System.out.println(ev.getName());
-            System.out.println(ev.readData());
+            System.out.println("ev.isEmpty() = " + ev.isEmpty());
+            System.out.println("event: " + ev.getName() + " " + ev.readData());
         }, thr -> {
             System.err.println("Error in SSE updates");
             thr.printStackTrace();
@@ -44,7 +44,7 @@ public void someMethod() {
         System.out.println("SSE opened");
         updateSource.open();
 
-        LockSupport.parkNanos(5_000_000_000L);
+        LockSupport.parkNanos(7_000_000_000L);
     }
 
 }
diff --git a/client/src/test/java/SseClientTest.java b/client/src/test/java/SseClientTest.java
diff --git a/server/src/main/java/com/sebastian_daschner/examples/UpdatesResource.java b/server/src/main/java/com/sebastian_daschner/examples/UpdatesResource.java
@@ -22,17 +22,19 @@ public class UpdatesResource {
 
     @GET
     public void updates(@Context SseEventSink eventSink) {
-        eventSink.send(createEvent());
+        eventSink.send(createEvent("test234", "test"));
         LockSupport.parkNanos(1_000_000_000L);
-        eventSink.send(createEvent());
+        eventSink.send(createEvent("test123", ""));
         LockSupport.parkNanos(1_000_000_000L);
-        eventSink.send(createEvent());
+        eventSink.send(createEvent("test234", "test"));
+        LockSupport.parkNanos(1_000_000_000L);
+        eventSink.send(createEvent("test123", ""));
     }
 
-    private OutboundSseEvent createEvent() {
+    private OutboundSseEvent createEvent(String name, String data) {
         return sse.newEventBuilder()
-                .name("test")
-                .data("test")
+                .name(name)
+                .data(data)
                 .build();
     }