Added SSE client implementation.

Author: lreimer

pom.xml

@@ -39,6 +39,12 @@
             <version>${jersey.version}</version>
             <scope>test</scope>
         </dependency>
+        <dependency>
+            <groupId>org.glassfish.jersey.media</groupId>
+            <artifactId>jersey-media-sse</artifactId>
+            <version>${jersey.version}</version>
+            <scope>test</scope>
+        </dependency>
 
     </dependencies>
 

src/test/java/com/packtpub/javaee8/SseClientIntegrationTest.java

@@ -8,8 +8,14 @@
 
 import javax.ws.rs.client.Client;
 import javax.ws.rs.client.ClientBuilder;
+import javax.ws.rs.client.Entity;
 import javax.ws.rs.client.WebTarget;
+import javax.ws.rs.core.MediaType;
+import javax.ws.rs.sse.SseEventSource;
+import java.util.concurrent.Executors;
+import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.TimeUnit;
+import java.util.logging.Level;
 import java.util.logging.Logger;
 
 @FixMethodOrder(MethodSorters.NAME_ASCENDING)
@@ -20,22 +26,37 @@ public class SseClientIntegrationTest {
     private Client client;
     private WebTarget webTarget;
 
+    private ScheduledExecutorService executorService;
+
     @Before
     public void setUp() {
         client = ClientBuilder.newBuilder()
                 .connectTimeout(5, TimeUnit.SECONDS).readTimeout(30, TimeUnit.SECONDS)
                 .build();
 
-        webTarget = client.target("http://localhost:8080").path("/sse-service/api");
+        webTarget = client.target("http://localhost:8080").path("/sse-service/api/events");
+        executorService = Executors.newSingleThreadScheduledExecutor();
     }
 
     @After
     public void tearDown() {
         client.close();
+        executorService.shutdown();
     }
 
     @Test
     public void receiveSse() throws Exception {
-        // TODO implement me
+
+        executorService.scheduleWithFixedDelay(() -> {
+            webTarget.request().post(Entity.entity("Hello SSE JAX-RS client.", MediaType.TEXT_PLAIN_TYPE));
+        }, 250, 500, TimeUnit.MILLISECONDS);
+
+        try (SseEventSource eventSource = SseEventSource.target(webTarget).build()) {
+            eventSource.register((e) -> LOGGER.log(Level.INFO, "Recieved event {0} with data {1}.",
+                    new Object[]{e.getName(), e.readData()}));
+            eventSource.open();
+
+            TimeUnit.SECONDS.sleep(3);
+        }
     }
 }