com.crankuptheamps.client

Class MemoryPublishStore

java.lang.Object

com.crankuptheamps.client.BlockPublishStore

com.crankuptheamps.client.MemoryPublishStore

All Implemented Interfaces:

Store, java.lang.AutoCloseable

public class MemoryPublishStore
extends BlockPublishStore

An in-memory publish store, used to provide republish capability when a server fails over.

Publish stores hold messages until the AMPS server has acknowledged that they are persisted. When the client detects disconnection and reconnects, the client can republish any messages which have not been acknowledged by AMPS.

Use this PublishStore when you are only concerned about server failover: MemoryPublishStore does not protect you in case of subscriber failure, because it has no persisted 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

_blockSize, _buffer, _errorOnPublishGap, _resizeHandler, allowGapCheck, AMPS_MIN_BLOCK_SIZE_CONFIGURABLE_VERSION, AMPS_MIN_PUB_STORE_DISCARDED_VERSION, MAX_BLOCK_SIZE, METADATA_BLOCK_SIZE_LOCATION, METADATA_LAST_DISCARDED_LOCATION, METADATA_VERSION_LOCATION, MIN_BLOCK_SIZE

Fields inherited from interface com.crankuptheamps.client.Store

SOWDeleteByBookmark, SOWDeleteByBookmarkCancel, SOWDeleteByData, SOWDeleteByFilter, SOWDeleteByKeys

Constructor Summary

Constructors

Constructor and Description
MemoryPublishStore(int initialCapacity) Construct an in-memory public store with the specified number of blocks as the initial capacity.
MemoryPublishStore(int initialCapacity, int blockSize) Construct an in-memory public store with the specified number of blocks of size blockSize as the initial capacity.

Method Summary

Methods inherited from class com.crankuptheamps.client.BlockPublishStore

close, discardUpTo, flush, flush, getErrorOnPublishGap, getHighestUnpersisted, getLastPersisted, getLowestUnpersisted, growFreeListIfEmpty, recover, replay, replaySingle, setErrorOnPublishGap, setMessage, setResizeHandler, 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

Construct an in-memory public store with the specified number of blocks as the initial capacity. The initial memory footprint will be initialCapacity * Block.DEFAULT_BLOCK_SIZE bytes.

Parameters:

initialCapacity - The number of blocks to allocate on construction

Throws:

StoreException - Thrown when an operation fails with details of the failure.

MemoryPublishStore

public MemoryPublishStore(int initialCapacity,
                          int blockSize)
                   throws StoreException

Construct an in-memory public store with the specified number of blocks of size blockSize as the initial capacity. The initial memory footprint will be initialCapacity * blockSize bytes.

Parameters:

initialCapacity - The number of blocks to allocate on construction

blockSize - The size in bytes for each block.

Throws:

StoreException - Thrown when an operation fails with details of the failure.