com.crankuptheamps.client
Class MemoryPublishStore

java.lang.Object
  extended by com.crankuptheamps.client.BlockPublishStore
      extended by 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.


Nested Class Summary
 
Nested classes/interfaces inherited from class com.crankuptheamps.client.BlockPublishStore
BlockPublishStore.Buffer, BlockPublishStore.ByteSequence
 
Nested classes/interfaces inherited from interface com.crankuptheamps.client.Store
Store.StoreReplayer
 
Field Summary
 
Fields inherited from class com.crankuptheamps.client.BlockPublishStore
_buffer, HAS_EXTENDED_METADATA
 
Fields inherited from interface com.crankuptheamps.client.Store
SOWDeleteByData, SOWDeleteByFilter, SOWDeleteByKeys
 
Constructor Summary
MemoryPublishStore(int initialCapacity)
           
 
Method Summary
 
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
 

Constructor Detail

MemoryPublishStore

public MemoryPublishStore(int initialCapacity)
                   throws StoreException
Throws:
StoreException