RecoveryPointAdapter (AMPS Java Client (5.3.2.1.6d15937f.540279))

All Superinterfaces:

java.lang.AutoCloseable, java.lang.Iterable<RecoveryPoint>, java.util.Iterator<RecoveryPoint>

All Known Implementing Classes:

ConflatingRecoveryPointAdapter, SOWRecoveryPointAdapter
```
public interface RecoveryPointAdapter
extends java.util.Iterator<RecoveryPoint>, java.lang.Iterable<RecoveryPoint>, java.lang.AutoCloseable
```
An instance of this interface that can optionally be provided to MemoryBookmarkStore when it's constructed to persist recovery bookmark state for each bookmark replay subscription. The adapter can persist this state to an external store and retrieve it on application restart so that bookmark replay subscriptions can be continued approximately where they left off (with the possible delivery of some duplicate messages). Typically the constructor of any implementation class will take resources needed to connect to / authenticate with the external store and a unique AMPS client name or session name (that stays consistent across application runs) that identifies the AMPS client whose bookmark replay subscriptions want to have their recovery state persisted by this adapter.

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method and Description
`void`	`purge()` This method is called by the associated bookmark store's purge() method (with the bookmark store lock held) with the expectation that the adapter will delete all recover point data stored for all subscriptions known to this adapter.
`void`	`purge(Field subId)` This method is called by the associated bookmark store's purge(subId) method (with the bookmark store lock held) with the expectation that the adapter will delete any recover point data stored for the specified subscription id.
`void`	`update(RecoveryPoint recoveryPoint)` This method should be implemented to write the passed in recovery point to the external store for the specified subscription.

Methods inherited from interface java.util.Iterator
forEachRemaining, hasNext, next, remove

Methods inherited from interface java.lang.Iterable
forEach, iterator, spliterator

Methods inherited from interface java.lang.AutoCloseable
close

- Method Detail
  - update
```
void update(RecoveryPoint recoveryPoint)
     throws java.lang.Exception
```
    This method should be implemented to write the passed in recovery point to the external store for the specified subscription. Only the latest recovery point needs to be kept for any given subscription id. When this adapter is registered directly with a bookmark store, this method is called by a bookmark store subscription (with its lock held) whenever the MOST_RECENT state of the subscription has potentially changed. If the associated bookmark store has multiple subscriptions, it's possible for this method to be called concurrently by each one, so this method should be implemented in a thread-safe manner. If this adapter is a delegate wrapped by a ConflatingRecoveryPointAdapter, then this method is only called by the conflating adapter's update thread periodically (never concurrently by multiple threads) without the subscription lock held.
    
    Parameters:
    
    recoveryPoint - The latest recovery point.
    
    Throws:
    
    java.lang.Exception - Should be thrown for any error writing recovery state to the external store.
  - purge
```
void purge(Field subId)
    throws java.lang.Exception
```
    This method is called by the associated bookmark store's purge(subId) method (with the bookmark store lock held) with the expectation that the adapter will delete any recover point data stored for the specified subscription id. Because the bookmark store lock is held when this is called, this method will only be invoked by one thread at a time.
    
    Parameters:
    
    subId - The id of the subscription being purged.
    
    Throws:
    
    java.lang.Exception - Should be thrown for any error deleting recovery state from the external store.
    
    See Also:
    
    BookmarkStore.purge(com.crankuptheamps.client.fields.Field)
  - purge
```
void purge()
    throws java.lang.Exception
```
    This method is called by the associated bookmark store's purge() method (with the bookmark store lock held) with the expectation that the adapter will delete all recover point data stored for all subscriptions known to this adapter. Because the bookmark store lock is held when this is called, this method will only be invoked by one thread at a time.
    
    Throws:
    
    java.lang.Exception - Should be thrown for any error deleting recovery state from the external store.
    
    See Also:
    
    BookmarkStore.purge()

Interface RecoveryPointAdapter

Method Summary

Methods inherited from interface java.util.Iterator

Methods inherited from interface java.lang.Iterable

Methods inherited from interface java.lang.AutoCloseable

Method Detail

update

purge

purge