Package org.glassfish.jersey.media.sse.internal

Class EventProcessor

java.lang.Object

org.glassfish.jersey.media.sse.internal.EventProcessor

All Implemented Interfaces:

Runnable, EventListener

public class EventProcessor
extends Object
implements Runnable, EventListener

Private event processor task responsible for connecting to the SSE stream and processing incoming SSE events as well as handling any connection issues.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	EventProcessor.Builder	EventProcessor builder.
static interface	EventProcessor.ShutdownHandler	Used to signal that the EventProcessor reached terminal stage.
static enum	EventProcessor.State	Event processor state, which is shared with the owner (to be able to control bootstrap and shutdown).

Method Summary

Modifier and Type	Method	Description
void	awaitFirstContact()	Await the initial contact with the SSE endpoint.
static EventProcessor.Builder	builder(WebTarget target, AtomicReference<EventProcessor.State> state, ClientExecutor clientExecutor, EventListener eventListener, EventProcessor.ShutdownHandler shutdownHandler)	Create new Event processor builder.
void	onEvent(InboundEvent event)	Called by the event source when an inbound event is received.
void	run()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

builder

public static EventProcessor.Builder builder(WebTarget target,
 AtomicReference<EventProcessor.State> state,
 ClientExecutor clientExecutor,
 EventListener eventListener,
 EventProcessor.ShutdownHandler shutdownHandler)

Create new Event processor builder.

Parameters:

target - web target to be used to call remote resource.

state - state shared with the owner of event processor instance.

clientExecutor - executor service used for consuming events and scheduling reconnects.

eventListener - event listener.

shutdownHandler - shutdown callback.

Returns:

new EventProcessor.Builder instance.

run

public void run()

Specified by:

run in interface Runnable

onEvent

public void onEvent(InboundEvent event)

Called by the event source when an inbound event is received. This listener aggregator method is responsible for invoking EventSource.onEvent(InboundEvent) method on the owning event source as well as for notifying all registered event listeners.

Specified by:

onEvent in interface EventListener

Parameters:

event - incoming inbound event.

awaitFirstContact

public void awaitFirstContact()

Await the initial contact with the SSE endpoint.