Interface ClusterMessageManager

All Known Implementing Classes:
ClusterMessageServiceImpl, NoOpClusterMessageService

@Internal public interface ClusterMessageManager
Administration interface for ClusterMessageService.
  • Method Summary

    Modifier and Type
    Method
    Description
    void
    Removes all stored messages older than the specified instant
    void
    Delete messages with timestamp older than an implementation-defined threshold.
     
    void
    Start polling for new messages.
    void
    Stop polling for new messages and ignore any late messages on start().
  • Method Details

    • start

      void start()
      Start polling for new messages.
    • stop

      void stop()
      Stop polling for new messages and ignore any late messages on start().
    • getAllMessages

      List<InternalClusterMessage> getAllMessages()
      Returns:
      all stored messages, including entries already processed or sent by the calling node.
    • deleteOldMessages

      void deleteOldMessages()
      Delete messages with timestamp older than an implementation-defined threshold.
    • deleteMessagesOlderThan

      void deleteMessagesOlderThan(Instant instant)
      Removes all stored messages older than the specified instant