quickfix

Class SleepycatStore

java.lang.Object

quickfix.SleepycatStore

All Implemented Interfaces:

MessageStore

public class SleepycatStore
extends Object
implements MessageStore

Sleepycat message and session state storage. This could be creating using the Sleepycat store factory.

See Also:

SleepycatStoreFactory

Constructor Summary

Constructors

Constructor and Description
SleepycatStore(SessionID sessionID, String databaseDir, String sequenceDbName, String messageDbName)

Method Summary

Modifier and Type	Method and Description
void	get(int startSequence, int endSequence, Collection<String> messages) Get messages within sequence number range (inclusive).
Date	getCreationTime() Get the session creation time.
int	getNextSenderMsgSeqNum()
int	getNextTargetMsgSeqNum()
void	incrNextSenderMsgSeqNum()
void	incrNextTargetMsgSeqNum()
void	refresh() Refresh session state from a shared state storage (e.g. database, file, ...).
void	reset() Reset the message store.
boolean	set(int sequence, String message) Adds a raw fix messages to the store with the given sequence number.
void	setNextSenderMsgSeqNum(int next)
void	setNextTargetMsgSeqNum(int next)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SleepycatStore

public SleepycatStore(SessionID sessionID,
                      String databaseDir,
                      String sequenceDbName,
                      String messageDbName)
               throws IOException

Throws:

IOException

Method Detail

get

public void get(int startSequence,
                int endSequence,
                Collection<String> messages)
         throws IOException

Description copied from interface: MessageStore

Get messages within sequence number range (inclusive). Used for message resend requests.

Specified by:

get in interface MessageStore

Parameters:

startSequence - the starting message sequence number.

endSequence - the ending message sequence number.

messages - the retrieved messages (out parameter)

Throws:

IOException - IO error

getCreationTime

public Date getCreationTime()
                     throws IOException

Description copied from interface: MessageStore

Get the session creation time.

Specified by:

getCreationTime in interface MessageStore

Returns:

the session creation time.

Throws:

IOException - IO error

getNextSenderMsgSeqNum

public int getNextSenderMsgSeqNum()
                           throws IOException

Specified by:

getNextSenderMsgSeqNum in interface MessageStore

Throws:

IOException

getNextTargetMsgSeqNum

public int getNextTargetMsgSeqNum()
                           throws IOException

Specified by:

getNextTargetMsgSeqNum in interface MessageStore

Throws:

IOException

incrNextSenderMsgSeqNum

public void incrNextSenderMsgSeqNum()
                             throws IOException

Specified by:

incrNextSenderMsgSeqNum in interface MessageStore

Throws:

IOException

incrNextTargetMsgSeqNum

public void incrNextTargetMsgSeqNum()
                             throws IOException

Specified by:

incrNextTargetMsgSeqNum in interface MessageStore

Throws:

IOException

reset

public void reset()
           throws IOException

Description copied from interface: MessageStore

Reset the message store. Sequence numbers are set back to 1 and stored messages are erased. The session creation time is also set to the time of the reset.

Specified by:

reset in interface MessageStore

Throws:

IOException - IO error

set

public boolean set(int sequence,
                   String message)
            throws IOException

Description copied from interface: MessageStore

Adds a raw fix messages to the store with the given sequence number. (Most implementations just append the message data to the store so be careful about assuming random access behavior.)

Specified by:

set in interface MessageStore

Parameters:

sequence - the sequence number

message - the raw FIX message string

Returns:

true is successful, false otherwise

Throws:

IOException - IO error

setNextSenderMsgSeqNum

public void setNextSenderMsgSeqNum(int next)
                            throws IOException

Specified by:

setNextSenderMsgSeqNum in interface MessageStore

Throws:

IOException

setNextTargetMsgSeqNum

public void setNextTargetMsgSeqNum(int next)
                            throws IOException

Specified by:

setNextTargetMsgSeqNum in interface MessageStore

Throws:

IOException

refresh

public void refresh()
             throws IOException

Description copied from interface: MessageStore

Refresh session state from a shared state storage (e.g. database, file, ...). Refresh will not work for message stores without shared state (e.g., MemoryStore). These stores should log an session error, at a minimum, or throw an exception.

Specified by:

refresh in interface MessageStore

Throws:

IOException