com.crankuptheamps.client
Class MemoryPublishStore
java.lang.Object
com.crankuptheamps.client.BlockPublishStore
com.crankuptheamps.client.MemoryPublishStore
- All Implemented Interfaces:
- Store
public class MemoryPublishStore
- extends BlockPublishStore
A PublishStore used to remember things you've published,
in case of failover to an AMPS secondary.
Use this PublishStore when you are concerned about server failover, only:
MemoryPublishStore does not protect you in case of subscriber failure, because
it has no on-disk backing store.
Methods inherited from class com.crankuptheamps.client.BlockPublishStore |
_store, discardUpTo, flush, flush, getLowestUnpersisted, growFreeListIfEmpty, recover, replay, replaySingle, setResizeHandler, store, store, store, unpersistedCount |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
MemoryPublishStore
public MemoryPublishStore(int initialCapacity)
throws StoreException
- Throws:
StoreException