biz.onixs.cme.ilink3.handler.storage

Class AsyncFileStorageRepository

java.lang.Object

biz.onixs.cme.ilink3.handler.storage.AbstractStorageRepository

biz.onixs.cme.ilink3.handler.storage.AsyncFileStorageRepository

All Implemented Interfaces:

StorageRepository

public class AsyncFileStorageRepository
extends AbstractStorageRepository

Asynchronous file-based session storage repository.

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_ASYNC_QUEUE_SIZE
static int	DEFAULT_WRITE_ERROR_NUMBER

Constructor Summary

Constructors

Constructor and Description
AsyncFileStorageRepository()

Method Summary

Modifier and Type	Method and Description
SessionStorage	create(SessionId sessionId, ByteDecoder decoder, boolean cleanStart) Creates session storage from scratch or restores from its previous state.
int	getAsyncQueueSize() Returns asynchronous operations queue size.
int	getWriteErrorRetriesNumber() Returns write error retries number.
void	setAsyncQueueSize(int asyncQueueSize) Sets asynchronous operations queue size.
void	setWriteErrorRetriesNumber(int writeErrorRetriesNumber) Sets write error retries number.
String	toString()

Methods inherited from class biz.onixs.cme.ilink3.handler.storage.AbstractStorageRepository

getMaxStorageSize, setMaxStorageSize

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

DEFAULT_ASYNC_QUEUE_SIZE

public static final int DEFAULT_ASYNC_QUEUE_SIZE

See Also:

Constant Field Values

DEFAULT_WRITE_ERROR_NUMBER

public static final int DEFAULT_WRITE_ERROR_NUMBER

See Also:

Constant Field Values

Constructor Detail

AsyncFileStorageRepository

public AsyncFileStorageRepository()

Method Detail

getAsyncQueueSize

public int getAsyncQueueSize()

Returns asynchronous operations queue size.

Returns:

asynchronous operations queue size

setAsyncQueueSize

public void setAsyncQueueSize(int asyncQueueSize)

Sets asynchronous operations queue size.

Parameters:

asyncQueueSize - asynchronous operations queue size

Throws:

IllegalArgumentException - if asyncBufferSize < 1

getWriteErrorRetriesNumber

public int getWriteErrorRetriesNumber()

Returns write error retries number.

Returns:

write error retries number

setWriteErrorRetriesNumber

public void setWriteErrorRetriesNumber(int writeErrorRetriesNumber)

Sets write error retries number. The max number of retries in case of I/O error while writing a message into storage.

Parameters:

writeErrorRetriesNumber - write error retries number

Throws:

IllegalArgumentException - if writeErrorRetriesNumber < 0

create

public SessionStorage create(SessionId sessionId,
                             ByteDecoder decoder,
                             boolean cleanStart)

Description copied from interface: StorageRepository

Creates session storage from scratch or restores from its previous state.

Parameters:

sessionId - session id

decoder - byte decoder

cleanStart - clean previous session state if any

Returns:

session storage

toString

public String toString()

Overrides:

toString in class Object