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

Class EventProcessor.Builder

java.lang.Object

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

Enclosing class:

EventProcessor

public static class EventProcessor.Builder
extends Object

EventProcessor builder.

Method Summary

Modifier and Type	Method	Description
EventProcessor.Builder	boundListeners(Map<String,List<EventListener>> boundListeners)	Unbounded listeners will get notified about incoming events with particular name.
EventProcessor	build()	Build the EventProcessor.
EventProcessor.Builder	disableKeepAlive()	Disables keepalive.
EventProcessor.Builder	reconnectDelay(long reconnectDelay, TimeUnit unit)	Set initial reconnect delay.
EventProcessor.Builder	throwableConsumers(List<Consumer<Throwable>> throwableConsumers)	Set the consumers of Throwable occurring during connection.
EventProcessor.Builder	unboundListeners(List<EventListener> unboundListeners)	Unbounded listeners will get notified about any incoming event.

Methods inherited from class java.lang.Object

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

Method Details

reconnectDelay

public EventProcessor.Builder reconnectDelay(long reconnectDelay,
 TimeUnit unit)

Set initial reconnect delay. Reconnect delay can be controlled by the server side, adding specific properties to incoming events.

Parameters:

reconnectDelay - reconnect delay value.

unit - reconnect delay timeunit.

Returns:

updated builder instance.

unboundListeners

public EventProcessor.Builder unboundListeners(List<EventListener> unboundListeners)

Unbounded listeners will get notified about any incoming event.

Parameters:

unboundListeners - list of listeners.

Returns:

updated builder instance.

boundListeners

public EventProcessor.Builder boundListeners(Map<String,List<EventListener>> boundListeners)

Unbounded listeners will get notified about incoming events with particular name.

Parameters:

boundListeners - map of bound listeners, key is a name to which listeners are bound to, value is a list of listeners.

Returns:

updated builder instance.

See Also:

• SseEvent.getName()

disableKeepAlive

public EventProcessor.Builder disableKeepAlive()

Disables keepalive.

Returns:

updated builder instance.

throwableConsumers

public EventProcessor.Builder throwableConsumers(List<Consumer<Throwable>> throwableConsumers)

Set the consumers of Throwable occurring during connection.

Parameters:

throwableConsumers - a list of consumers of throwable.

Returns:

updated builder instance.

build

public EventProcessor build()

Build the EventProcessor.

Returns:

built Event processor instance.