This method discards all operations up to the index provided.
The sequence id to keep. All previous sequence numbers will be discarded.
This method returns the last persisted sequence id in the store.
The sequence number of the last discarded message.
This method returns the oldest sequence in the store.
The oldest sequence number in the store.
This method replays all messages in the store using the provided message sender.
The sender that will re-send the messages.
This method replays the message with the specified sequenceId.
The sender that will re-send the message.
The sequence id of the message to replay.
Store the provided message. The sequence of the message is a key that the client can later use to replay the operation or remove the operation from the store. Implementations may assume that the sequence increases monotonically.
The message that contains fields like command name, topic name, data, etc.
This method returns the number of messages in the store.
The number of messages in the store.
MemoryPublishStore represents the default implementation of the in-memory publish store. The AMPS client uses publish stores for recovery purposes. The store is responsible for maintaining the state of published messages and recovering that state in the event of a disconnection.