AMPS.Client.MemoryPublishStore Class Reference

Inheritance diagram for AMPS.Client.MemoryPublishStore:

Public Member Functions
	MemoryPublishStore (int initialCapacity)
override void	Dispose ()
Public Member Functions inherited from AMPS.Client.BlockPublishStore
void	store (Message m)
void	store (Message m, Boolean assignSequence)
void	discardUpTo (ulong index)
ulong	getLastPersisted ()
ulong	getLowestUnpersisted ()
ulong	getHighestUnpersisted ()
void	setMessage (Message message)
virtual void	replay (StoreReplayer replayer)
bool	replaySingle (StoreReplayer replayer, ulong index)
long	unpersistedCount ()
void	flush ()
void	flush (int timeout)
void	setResizeHandler (PublishStoreResizeHandler handler)

Additional Inherited Members
Protected Member Functions inherited from AMPS.Client.BlockPublishStore
	BlockPublishStore (Buffer buffer, int blocksPerRealloc)
	BlockPublishStore (Buffer buffer, bool useCrc=false, int blocksPerRealloc=10000)
void	recover ()
void	growFreeListIfEmpty ()
Protected Attributes inherited from AMPS.Client.BlockPublishStore
PublishStoreResizeHandler	_resizeHandler = null
Buffer	_buffer
Utilities.CRC32	_crc = null

Constructor & Destructor Documentation

MemoryPublishStore()

AMPS.Client.MemoryPublishStore.MemoryPublishStore ( int  initialCapacity )

inline

Creates a new MemoryPublishStore.

Parameters

initialCapacity

The initial capacity (in 2k blocks) of the store. This size is also used when resizing the store: the store is resized by this value each time the store grows. A general guideline for initial capacity is to set the capacity to messages_published_per_second * int(average_message_size / block_size) + 1.

---

The documentation for this class was generated from the following file:

• AMPS.Client/MemoryPublishStore.cs