Package org.nuxeo.runtime.stream

Interface StreamService

All Known Implementing Classes:

StreamServiceImpl

public interface StreamService

Since:

9.3

Method Summary

Modifier and Type	Method	Description
LogManager	getLogManager()
default LogManager	getLogManager(String configName)	Deprecated. since 11.1 just use getLogManager().
StreamManager	getStreamManager()
default StreamManager	getStreamManager(String configName)	Deprecated. since 11.1 just use getStreamManager().
boolean	restartComputation(Name computation)	Restart the computation thread pool.
boolean	setComputationPositionAfterDate(Name computation, Name stream, Instant dateTime)	Moving computation position after a date.
boolean	setComputationPositionToBeginning(Name computation, Name stream)	Moving computation position to the beginning of stream.
boolean	setComputationPositionToEnd(Name computation, Name stream)	Moving computation position to the end of stream.
boolean	setComputationPositionToOffset(Name computation, Name stream, int partition, long offset)	Moving computation position to a specific offset for a partition.
boolean	startProcessor(String processorName)	Starts a registered Processor.
boolean	stopComputation(Name computation)	Stop computation thread pool immediately.
boolean	stopProcessor(String processorName)	Stop a running processor.
void	stopProcessors()

Method Detail

getLogManager

LogManager getLogManager()

getStreamManager

StreamManager getStreamManager()

getLogManager

@Deprecated(since="11.1")
default LogManager getLogManager(String configName)

Deprecated.

since 11.1 just use getLogManager().

Gets a LogManager corresponding to the config name. The service takes care of closing the manager on shutdown you should not do it directly.

getStreamManager

@Deprecated(since="11.1")
default StreamManager getStreamManager(String configName)

Deprecated.

since 11.1 just use getStreamManager().

Gets a StreamManager that uses a LogManager matching the config name.

stopProcessors

void stopProcessors()

startProcessor

boolean startProcessor(String processorName)

Starts a registered Processor. Returns true if the processor has been started.

Since:

2021.40

stopProcessor

boolean stopProcessor(String processorName)

Stop a running processor. Returns true if the processor has been stopped.

Since:

2021.40

stopComputation

boolean stopComputation(Name computation)

Stop computation thread pool immediately.

Since:

2021.25

restartComputation

boolean restartComputation(Name computation)

Restart the computation thread pool. Do nothing if the computation thread pool is already started.

Since:

2021.25

setComputationPositionToEnd

boolean setComputationPositionToEnd(Name computation,
                                    Name stream)

Moving computation position to the end of stream. The computation thread pool must be stopped using stopComputation(Name) before changing its position.

Since:

2021.25

setComputationPositionToBeginning

boolean setComputationPositionToBeginning(Name computation,
                                          Name stream)

Moving computation position to the beginning of stream. The computation thread pool must be stopped using stopComputation(Name) before changing its position.

Since:

2021.25

setComputationPositionToOffset

boolean setComputationPositionToOffset(Name computation,
                                       Name stream,
                                       int partition,
                                       long offset)

Moving computation position to a specific offset for a partition. The computation thread pool must be stopped using stopComputation(Name) before changing its position.

Since:

2021.25

setComputationPositionAfterDate

boolean setComputationPositionAfterDate(Name computation,
                                        Name stream,
                                        Instant dateTime)

Moving computation position after a date. The computation thread pool must be stopped using stopComputation(Name) before changing its position.

Since:

2021.25