Package jakarta.ws.rs.sse

Class SseEventSource.Builder

java.lang.Object

jakarta.ws.rs.sse.SseEventSource.Builder

Enclosing interface:

SseEventSource

public abstract static class SseEventSource.Builder
extends Object

JAX-RS SseEventSource builder class.

Event source builder provides methods that let you conveniently configure and subsequently build a new SseEventSource instance. You can obtain a new event source builder instance using a static SseEventSource.target(endpoint) factory method.

For example:

 SseEventSource es = SseEventSource.target(endpoint)
         .reconnectingEvery(5, SECONDS)
         .build();
 es.register(System.out::println);
 es.open();
 

Field Summary

Fields

Modifier and Type	Field	Description
static final String	JAXRS_DEFAULT_SSE_BUILDER_PROPERTY	Name of the property identifying the SseEventSource.Builder implementation to be returned from newBuilder().

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	Builder()	Allows custom implementations to extend the SSE event source builder class.

Method Summary

Modifier and Type	Method	Description
abstract SseEventSource	build()	Build new SSE event source pointing at a SSE streaming web target.
abstract SseEventSource.Builder	reconnectingEvery(long delay, TimeUnit unit)	Set the initial reconnect delay to be used by the event source.
protected abstract SseEventSource.Builder	target(WebTarget endpoint)	Set the SSE streaming endpoint.

Methods inherited from class java.lang.Object

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

Field Details

JAXRS_DEFAULT_SSE_BUILDER_PROPERTY

public static final String JAXRS_DEFAULT_SSE_BUILDER_PROPERTY

Name of the property identifying the SseEventSource.Builder implementation to be returned from newBuilder().

See Also:

• Constant Field Values

Constructor Details

Builder

protected Builder()

Allows custom implementations to extend the SSE event source builder class.

Method Details

target

protected abstract SseEventSource.Builder target(WebTarget endpoint)

Set the SSE streaming endpoint.

Parameters:

endpoint - SSE streaming endpoint. Must not be null.

Returns:

updated event source builder instance.

Throws:

NullPointerException - in case the supplied web target is null.

reconnectingEvery

public abstract SseEventSource.Builder reconnectingEvery(long delay,
 TimeUnit unit)

Set the initial reconnect delay to be used by the event source.

Note that this value may be later overridden by the SSE endpoint using either a retry SSE event field or HTTP 503 + "Retry-After" mechanism as described in the SseEventSource javadoc.

Parameters:

delay - the default time to wait before attempting to recover from a connection loss.

unit - time unit of the reconnect delay parameter.

Returns:

updated event source builder instance.

build

public abstract SseEventSource build()

Build new SSE event source pointing at a SSE streaming web target.

The returned event source is ready, but not connected to the SSE endpoint. It is expected that you will manually invoke its SseEventSource.open() method once you are ready to start receiving SSE events. In case you want to build an event source instance that is already connected to the SSE endpoint, use the event source builder SseEventSource.open() method instead.

Once the event source is open, the incoming events are processed by the event source in an asynchronous task that runs in an internal single-threaded scheduled executor service.

Returns:

new event source instance, ready to be connected to the SSE endpoint.

See Also:

• SseEventSource.open()