Interface ClusterMessageManager
- All Known Implementing Classes:
ClusterMessageServiceImpl,NoOpClusterMessageService
@Internal
public interface ClusterMessageManager
Administration interface for
ClusterMessageService.-
Method Summary
Modifier and TypeMethodDescriptionvoiddeleteMessagesOlderThan(Instant instant) Removes all stored messages older than the specified instantvoidDelete messages with timestamp older than an implementation-defined threshold.voidstart()Start polling for new messages.voidstop()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
Removes all stored messages older than the specified instant
-