examples/sse-twitter-aggregator/src/main/resources/webroot/js/sse-client.js

/*
 * Copyright (c) 2012, 2018 Oracle and/or its affiliates. All rights reserved.
 *
 * This program and the accompanying materials are made available under the
 * terms of the Eclipse Distribution License v. 1.0, which is available at
 * http://www.eclipse.org/org/documents/edl-v10.php.
 *
 * SPDX-License-Identifier: BSD-3-Clause
 */

"use strict";

function receiveMessages() {
    if (typeof(EventSource) !== "undefined") {
        // Yes! Server-sent events support!
        var sourceJersey = new EventSource('/aggregator-api/message/stream/jersey');
        var sourceJaxRs = new EventSource('/aggregator-api/message/stream/jaxrs');
        var eventHandler =function (event) {
            var data = JSON.parse(event.data);
            console.log(data);

            var newEntry =
                '<div class="message">'
                    + '<img src="' + data.user.profile_image_url + '" />'
                    + '<span style="color: #' + data.rgbColor + '">'
                    + data.text + '</span></div>';

            document.body.innerHTML = newEntry + document.body.innerHTML;
        };
        sourceJersey.onmessage = eventHandler;
        sourceJaxRs.onmessage = eventHandler;

        sourceJersey.onopen = function (event) {
            // Connection was opened.
            console.log('Jresey stream opened.')
        };

        sourceJaxRs.onopen = function (event) {
            console.log('JAX-RS stream opened.')
        }

        sourceJersey.onclose = function (event) {
            // Connection was closed.
            console.log('Jersey connection closed')
        };

        sourceJaxRs.onclose = function (event) {
            // Connection was closed.
            console.log('JAX-RS connection closed')
        };
    } else {
        // Sorry! No server-sent events support..
        console.log('SSE not supported by browser.')
    }
}

window.onload = receiveMessages ;