Class FileSessionStore

java.lang.Object

com.quantfinlib.fix.FileSessionStore

All Implemented Interfaces:

FixSessionStore, AutoCloseable

public final class FileSessionStore
extends Object
implements FixSessionStore, AutoCloseable

Durable FixSessionStore backed by two files in a directory: seqnums.dat (16 bytes, synchronous writes) and an append-only messages.dat replayed into memory on open. Reopening the store after a process restart resumes the FIX session with sequence-number continuation and a fully serviceable resend history.

Nested Class Summary

Nested classes/interfaces inherited from interface com.quantfinlib.fix.FixSessionStore

FixSessionStore.InMemory, FixSessionStore.StoredMessage

Constructor Summary

Constructors

Constructor	Description
FileSessionStore(Path directory)

Method Summary

Modifier and Type	Method	Description
void	close()
long	expectedIncomingSeq()	The next incoming MsgSeqNum expected (1 for a fresh session).
long	nextOutgoingSeq()	The next outgoing MsgSeqNum to use (1 for a fresh session).
FixSessionStore.StoredMessage	retrieve(long seq)	The stored message at seq, or null (admin / never sent).
void	saveIncomingSeq(long expectedSeq)
void	saveOutgoingSeq(long nextSeq)
void	storeMessage(long seq, FixSessionStore.StoredMessage message)

Methods inherited from class java.lang.Object

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

Constructor Details

FileSessionStore

public FileSessionStore(Path directory)
                 throws IOException

Throws:

IOException

Method Details

nextOutgoingSeq

public long nextOutgoingSeq()

Description copied from interface: FixSessionStore

The next outgoing MsgSeqNum to use (1 for a fresh session).

Specified by:

nextOutgoingSeq in interface FixSessionStore

expectedIncomingSeq

public long expectedIncomingSeq()

Description copied from interface: FixSessionStore

The next incoming MsgSeqNum expected (1 for a fresh session).

Specified by:

expectedIncomingSeq in interface FixSessionStore

saveOutgoingSeq

public void saveOutgoingSeq(long nextSeq)

Specified by:

saveOutgoingSeq in interface FixSessionStore

saveIncomingSeq

public void saveIncomingSeq(long expectedSeq)

Specified by:

saveIncomingSeq in interface FixSessionStore

storeMessage

public void storeMessage(long seq,
 FixSessionStore.StoredMessage message)

Specified by:

storeMessage in interface FixSessionStore

retrieve

public FixSessionStore.StoredMessage retrieve(long seq)

Description copied from interface: FixSessionStore

The stored message at seq, or null (admin / never sent).

Specified by:

retrieve in interface FixSessionStore

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Throws:

IOException