|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectbiz.onixs.fix.engine.storage.TimingSessionStorage
public class TimingSessionStorage
Constructor Summary | |
---|---|
TimingSessionStorage(SessionStorage storage)
|
Method Summary | |
---|---|
void |
clear()
Clears session storage state. Inbound and outbound sequence numbers are reset to 0. |
void |
close(boolean terminated)
Closes session storage. The terminated set to true means that after closing this session storage can not be restored. |
String |
getId()
Returns session storage unique id. |
long |
getInSeqNum()
Returns last inbound message sequence number or 0 if no inbound message is stored. |
long |
getMaxStorageSize()
Returns the maximum size of the storage in messages. |
Message |
getMessage(MessageDirection direction,
long sequenceNumber)
Returns last message with the specified direction and sequence number. |
List<Message> |
getMessages(MessageDirection direction,
long beginSequenceNumber,
long endSequenceNumber)
Returns messages with the specified direction and sequence number interval. |
long |
getOutSeqNum()
Returns last outbound sequence number or 0 if no outbound message is stored. |
boolean |
isTerminated()
Returns the flag whether this storage state should be kept or cleaned. |
void |
open()
Opens session storage. |
void |
setInSeqNum(long msgSeqNum)
Sets last inbound message sequence number |
void |
setMaxStorageSize(long maxStorageSize)
Sets the maximum size of the storage in messages. |
void |
setOutSeqNum(long msgSeqNum)
Sets last outbound message sequence number. |
void |
setTerminated(boolean terminated)
Sets the flag whether this storage state should be kept or cleaned |
void |
storeMessage(MessageDirection direction,
long msgSeqNum,
biz.onixs.util.ByteBuffer rawMessage)
Stores message. |
void |
storeMessage(MessageDirection direction,
Message message,
biz.onixs.util.ByteBuffer rawMessage)
Stores message. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public TimingSessionStorage(SessionStorage storage)
Method Detail |
---|
public void clear()
SessionStorage
clear
in interface SessionStorage
public void open()
SessionStorage
open
in interface SessionStorage
public void close(boolean terminated)
SessionStorage
close
in interface SessionStorage
terminated
- controls whether this session storage state should be kept or cleanedpublic Message getMessage(MessageDirection direction, long sequenceNumber)
SessionStorage
getMessage
in interface SessionStorage
direction
- message directionsequenceNumber
- message sequence number
public List<Message> getMessages(MessageDirection direction, long beginSequenceNumber, long endSequenceNumber)
SessionStorage
getMessages
in interface SessionStorage
direction
- messages directionbeginSequenceNumber
- sequence number to begin with, 0 means the minimum availableendSequenceNumber
- sequence number to end with, 0 means the maximum available
public void setMaxStorageSize(long maxStorageSize)
SessionStorage
setMaxStorageSize
in interface SessionStorage
maxStorageSize
- maximum size of the message storagepublic long getMaxStorageSize()
SessionStorage
getMaxStorageSize
in interface SessionStorage
public String getId()
SessionStorage
getId
in interface SessionStorage
public long getInSeqNum()
SessionStorage
getInSeqNum
in interface SessionStorage
public void setInSeqNum(long msgSeqNum)
SessionStorage
setInSeqNum
in interface SessionStorage
msgSeqNum
- inbound message sequence numberpublic void storeMessage(MessageDirection direction, Message message, biz.onixs.util.ByteBuffer rawMessage)
SessionStorage
storeMessage
in interface SessionStorage
direction
- message directionmessage
- message to storerawMessage
- message to store in a raw formatpublic void storeMessage(MessageDirection direction, long msgSeqNum, biz.onixs.util.ByteBuffer rawMessage)
SessionStorage
storeMessage
in interface SessionStorage
direction
- message directionmsgSeqNum
- message sequence numberrawMessage
- message to storepublic boolean isTerminated()
SessionStorage
isTerminated
in interface SessionStorage
public void setTerminated(boolean terminated)
SessionStorage
setTerminated
in interface SessionStorage
terminated
- flag whether this storage state should be kept or cleanedpublic long getOutSeqNum()
SessionStorage
getOutSeqNum
in interface SessionStorage
public void setOutSeqNum(long msgSeqNum)
SessionStorage
setOutSeqNum
in interface SessionStorage
msgSeqNum
- last outbound message sequence number
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |