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