biz.onixs.fix.engine.storage
Class TimingSessionStorage

java.lang.Object
  extended by biz.onixs.fix.engine.storage.TimingSessionStorage
All Implemented Interfaces:
SessionStorage

public class TimingSessionStorage
extends Object
implements SessionStorage


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

TimingSessionStorage

public TimingSessionStorage(SessionStorage storage)
Method Detail

clear

public void clear()
Description copied from interface: SessionStorage
Clears session storage state.
Inbound and outbound sequence numbers are reset to 0.

Specified by:
clear in interface SessionStorage

open

public void open()
Description copied from interface: SessionStorage
Opens session storage.

Specified by:
open in interface SessionStorage

close

public void close(boolean terminated)
Description copied from interface: SessionStorage
Closes session storage.
The terminated set to true means that after closing this session storage can not be restored. Its state is vanished. The session with the same parameters will be started from scratch.
The terminated set to false means that after closing this session can be restored at some point in the future. The session state need to be kept - sequence numbers, etc.

Specified by:
close in interface SessionStorage
Parameters:
terminated - controls whether this session storage state should be kept or cleaned

getMessage

public Message getMessage(MessageDirection direction,
                          long sequenceNumber)
Description copied from interface: SessionStorage
Returns last message with the specified direction and sequence number.

Specified by:
getMessage in interface SessionStorage
Parameters:
direction - message direction
sequenceNumber - message sequence number
Returns:
message or null if not available

getMessages

public List<Message> getMessages(MessageDirection direction,
                                 long beginSequenceNumber,
                                 long endSequenceNumber)
Description copied from interface: SessionStorage
Returns messages with the specified direction and sequence number interval. Ends are included.

Specified by:
getMessages in interface SessionStorage
Parameters:
direction - messages direction
beginSequenceNumber - sequence number to begin with, 0 means the minimum available
endSequenceNumber - sequence number to end with, 0 means the maximum available
Returns:
outbound messages

setMaxStorageSize

public void setMaxStorageSize(long maxStorageSize)
Description copied from interface: SessionStorage
Sets the maximum size of the storage in messages.

Specified by:
setMaxStorageSize in interface SessionStorage
Parameters:
maxStorageSize - maximum size of the message storage

getMaxStorageSize

public long getMaxStorageSize()
Description copied from interface: SessionStorage
Returns the maximum size of the storage in messages.

Specified by:
getMaxStorageSize in interface SessionStorage
Returns:
maximum size of the message storage

getId

public String getId()
Description copied from interface: SessionStorage
Returns session storage unique id.

Specified by:
getId in interface SessionStorage
Returns:
session storage unique id

getInSeqNum

public long getInSeqNum()
Description copied from interface: SessionStorage
Returns last inbound message sequence number or 0 if no inbound message is stored.

Specified by:
getInSeqNum in interface SessionStorage
Returns:
inbound sequence number

setInSeqNum

public void setInSeqNum(long msgSeqNum)
Description copied from interface: SessionStorage
Sets last inbound message sequence number

Specified by:
setInSeqNum in interface SessionStorage
Parameters:
msgSeqNum - inbound message sequence number

storeMessage

public void storeMessage(MessageDirection direction,
                         Message message,
                         biz.onixs.util.ByteBuffer rawMessage)
Description copied from interface: SessionStorage
Stores message.

Specified by:
storeMessage in interface SessionStorage
Parameters:
direction - message direction
message - message to store
rawMessage - message to store in a raw format

storeMessage

public void storeMessage(MessageDirection direction,
                         long msgSeqNum,
                         biz.onixs.util.ByteBuffer rawMessage)
Description copied from interface: SessionStorage
Stores message.

Specified by:
storeMessage in interface SessionStorage
Parameters:
direction - message direction
msgSeqNum - message sequence number
rawMessage - message to store

isTerminated

public boolean isTerminated()
Description copied from interface: SessionStorage
Returns the flag whether this storage state should be kept or cleaned.

Specified by:
isTerminated in interface SessionStorage
Returns:
flag whether this storage state should be kept or cleaned

setTerminated

public void setTerminated(boolean terminated)
Description copied from interface: SessionStorage
Sets the flag whether this storage state should be kept or cleaned

Specified by:
setTerminated in interface SessionStorage
Parameters:
terminated - flag whether this storage state should be kept or cleaned

getOutSeqNum

public long getOutSeqNum()
Description copied from interface: SessionStorage
Returns last outbound sequence number or 0 if no outbound message is stored.

Specified by:
getOutSeqNum in interface SessionStorage
Returns:
outbound sequence number

setOutSeqNum

public void setOutSeqNum(long msgSeqNum)
Description copied from interface: SessionStorage
Sets last outbound message sequence number.

Specified by:
setOutSeqNum in interface SessionStorage
Parameters:
msgSeqNum - last outbound message sequence number


Copyright © 2005-2012 Onix Solutions. All Rights Reserved.