Module com.airepublic.http.sse.api

Package com.airepublic.http.sse.api

Interface ISseRegistry

All Superinterfaces:

java.lang.AutoCloseable, java.io.Closeable

public interface ISseRegistry
extends java.io.Closeable

Method Summary

Modifier and Type	Method	Description
java.util.Map<java.net.URI,java.util.concurrent.Future<java.lang.Void>>	getAllConsumers()	Gets all registered SseConsumers.
java.util.concurrent.Future<java.lang.Void>	getSseConsumer(java.net.URI uri)	Gets a registered SseConsumer.
ProducerEntry	getSseProducer(java.lang.String path)	Gets a registered SseProducer.
void	registerSseConsumer(java.net.URI uri, java.util.concurrent.Future<java.lang.Void> sseConsumer)	Registers a SseConsumer.
void	registerSseProducer(java.lang.String path, java.lang.Class<?> clazz, java.lang.reflect.Method method)	Registers a SseProducer.
java.util.concurrent.Future<java.lang.Void>	unregisterSseConsumer(java.net.URI uri)	Unregisters a SseConsumer.
void	unregisterSseProducer(java.lang.String path)	Unregisters a SseProducer.

Methods inherited from interface java.io.Closeable

close

Method Detail

registerSseProducer

void registerSseProducer(java.lang.String path,
                         java.lang.Class<?> clazz,
                         java.lang.reflect.Method method)

Registers a SseProducer.

Parameters:

path - the URI path to register the SseProducer for.

clazz - the producer class

method - the producer Method

unregisterSseProducer

void unregisterSseProducer(java.lang.String path)

Unregisters a SseProducer.

Parameters:

path - the URI path to register the SseProducer for.

getSseProducer

ProducerEntry getSseProducer(java.lang.String path)

Gets a registered SseProducer.

Parameters:

path - the URI path to register the SseProducer for.

Returns:

the ProducerEntry for the registered SseProducer or null

registerSseConsumer

void registerSseConsumer(java.net.URI uri,
                         java.util.concurrent.Future<java.lang.Void> sseConsumer)

Registers a SseConsumer.

Parameters:

uri - the URI of the event source

sseConsumer - the Future returned from calling ISseService.receive(URI, java.util.function.Consumer)

getSseConsumer

java.util.concurrent.Future<java.lang.Void> getSseConsumer(java.net.URI uri)

Gets a registered SseConsumer.

Parameters:

uri - the URI of the event source

Returns:

the Future returned from calling ISseService.receive(URI, java.util.function.Consumer)

unregisterSseConsumer

java.util.concurrent.Future<java.lang.Void> unregisterSseConsumer(java.net.URI uri)

Unregisters a SseConsumer.

Parameters:

uri - the URI of the event source

Returns:

the Future returned from calling ISseService.receive(URI, java.util.function.Consumer)

getAllConsumers

java.util.Map<java.net.URI,java.util.concurrent.Future<java.lang.Void>> getAllConsumers()

Gets all registered SseConsumers.

Returns:

a mapping of URI of the event source and the Future returned from calling ISseService.receive(URI, java.util.function.Consumer)