Package org.nuxeo.runtime.stream

Interface StreamService

All Known Implementing Classes:
StreamServiceImpl
public interface StreamService
Since:
9.3

  • Method Details

    • 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