Added SSE broadcast example.

lreimer · lreimer · commit 1188f1865496 · 2018-03-14T12:43:35.000+01:00
diff --git a/src/main/java/com/packtpub/javaee8/BroadcastResource.java b/src/main/java/com/packtpub/javaee8/BroadcastResource.java
@@ -0,0 +1,40 @@
+package com.packtpub.javaee8;
+
+import javax.annotation.PostConstruct;
+import javax.enterprise.context.ApplicationScoped;
+import javax.ws.rs.*;
+import javax.ws.rs.core.Context;
+import javax.ws.rs.core.MediaType;
+import javax.ws.rs.core.Response;
+import javax.ws.rs.sse.OutboundSseEvent;
+import javax.ws.rs.sse.Sse;
+import javax.ws.rs.sse.SseBroadcaster;
+import javax.ws.rs.sse.SseEventSink;
+
+@ApplicationScoped
+@Path("broadcast")
+public class BroadcastResource {
+
+    @Context
+    private Sse sse;
+    private SseBroadcaster sseBroadcaster;
+
+    @PostConstruct
+    public void initialize() {
+        sseBroadcaster = sse.newBroadcaster();
+    }
+
+    @GET
+    @Produces(MediaType.SERVER_SENT_EVENTS)
+    public void fetch(@Context SseEventSink sseEventSink) {
+        sseBroadcaster.register(sseEventSink);
+    }
+
+    @POST
+    @Consumes(MediaType.APPLICATION_FORM_URLENCODED)
+    public Response broadcast(@FormParam("message") String message) {
+        OutboundSseEvent broadcastEvent = sse.newEvent("message", message);
+        sseBroadcaster.broadcast(broadcastEvent);
+        return Response.noContent().build();
+    }
+}
diff --git a/src/main/webapp/broadcast.jsp b/src/main/webapp/broadcast.jsp
@@ -0,0 +1,29 @@
+<%@ page contentType="text/html;charset=UTF-8" language="java" %>
+<!DOCTYPE html>
+<html>
+<head>
+    <title>Simple SSE broadcast</title>
+</head>
+<body>
+
+<form action="/sse-service/api/broadcast" method="post">
+    Message <input type="text" name="message"/>
+    <input type="submit" value="Submit"/>
+</form>
+
+<h2>Chat messages</h2>
+<div id="messages"></div>
+
+<script>
+    if (typeof(EventSource) !== "undefined") {
+        var source = new EventSource("http://localhost:8080/sse-service/api/broadcast");
+
+        source.addEventListener("message", function (e) {
+            document.getElementById("messages").innerHTML += e.data + "<br>";
+        }, false);
+    } else {
+        document.getElementById("messages").innerHTML = "Sorry, your browser does not support server-sent events...";
+    }
+</script>
+</body>
+</html>
