public abstract static class SseEventSource.Builder
extends java.lang.Object
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();
| Modifier and Type | Field and Description |
|---|---|
static java.lang.String |
JAXRS_DEFAULT_SSE_BUILDER_PROPERTY
Name of the property identifying the
SseEventSource.Builder implementation
to be returned from newBuilder(). |
| Modifier | Constructor and Description |
|---|---|
protected |
Builder()
Allows custom implementations to extend the SSE event source builder class.
|
| Modifier and Type | Method and Description |
|---|---|
abstract SseEventSource |
build()
Build new SSE event source pointing at a SSE streaming
web target. |
abstract SseEventSource.Builder |
reconnectingEvery(long delay,
java.util.concurrent.TimeUnit unit)
Set the initial reconnect delay to be used by the event source.
|
protected abstract SseEventSource.Builder |
target(WebTarget endpoint) |
public static final java.lang.String JAXRS_DEFAULT_SSE_BUILDER_PROPERTY
SseEventSource.Builder implementation
to be returned from newBuilder().protected Builder()
protected abstract SseEventSource.Builder target(WebTarget endpoint)
public abstract SseEventSource.Builder reconnectingEvery(long delay, java.util.concurrent.TimeUnit unit)
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.
delay - the default time to wait before attempting to recover from a connection loss.unit - time unit of the reconnect delay parameter.public abstract SseEventSource build()
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.
SseEventSource.open()