Package org.apache.juneau.rest.server.sse

Class SseBroadcaster

java.lang.Object

org.apache.juneau.rest.server.sse.SseBroadcaster

public class SseBroadcaster
extends Object

In-memory server-side SSE broadcaster.

Constructor Summary

Constructors

Constructor	Description
SseBroadcaster(int queueSize)	Constructor.

Method Summary

Modifier and Type	Method	Description
static SseBroadcaster	create()	Creates a broadcaster with the default queue size.
void	publish(SseEvent event)	Publishes an event to all active subscribers.
SseSubscription	subscribe(String id)	Creates or replaces a subscriber.

Methods inherited from class java.lang.Object

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

Constructor Details

SseBroadcaster

public SseBroadcaster(int queueSize)

Constructor.

Parameters:

queueSize - The per-subscriber queue size.

Method Details

create

public static SseBroadcaster create()

Creates a broadcaster with the default queue size.

Returns:

A new broadcaster.

subscribe

public SseSubscription subscribe(String id)

Creates or replaces a subscriber.

Parameters:

id - The subscriber identifier. Must not be null or empty.

Returns:

A new subscription.

publish

public void publish(SseEvent event)

Publishes an event to all active subscribers.

Parameters:

event - The event to publish. Can be null (ignored).