biz.onixs.cme.ilink3.handler.storage

Class TimingSessionStorage

java.lang.Object

biz.onixs.cme.ilink3.handler.storage.TimingSessionStorage

All Implemented Interfaces:

SessionStorage

public class TimingSessionStorage
extends Object
implements SessionStorage

Constructor Summary

Constructors

Constructor and Description
TimingSessionStorage(SessionStorage storage)

Method Summary

Modifier and Type	Method and Description
void	clear() Clears session storage state.
void	close(boolean terminated) Closes session storage.
long	getInSeqNum() Returns last inbound message sequence number or 0 if no inbound message is stored.
int	getMaxStorageSize() Returns the maximum size of the message storage.
List<IMessage>	getOutboundMessages(long beginSequenceNumber, long endSequenceNumber) Returns outbound messages with the specified sequence number interval.
long	getOutSeqNum() Returns last outbound sequence number or 0 if no outbound message is stored.
long	getPreviousSeqNo() Returns last inbound message sequence number of previous session or 0 if no inbound message is stored.
long	getPreviousUuid() Returns previous Universally Unique Identifier (UUID).
SessionStorage	getUnderlyingStorage()
long	getUuid() Returns Universally Unique Identifier (UUID).
boolean	isNegotiated() Returns whether the session is negotiated.
boolean	isTerminated() Returns the flag whether this storage state should be kept or cleaned.
void	setInSeqNum(long msgSeqNum) Sets last inbound message sequence number
void	setMaxStorageSize(int maxStorageSize) Sets the maximum size of the message storage.
void	setNegotiated(boolean value) Sets whether the session is negotiated.
void	setOutSeqNum(long msgSeqNum) Sets last outbound message sequence number.
void	setPreviousSeqNo(long seqNo) Sets last inbound message sequence number of previous session
void	setPreviousUuid(long uuid) Sets previous Universally Unique Identifier (UUID).
void	setTerminated(boolean terminated) Sets the flag whether this storage state should be kept or cleaned
void	setUuid(long uuid) Sets Universally Unique Identifier (UUID).
void	storeInboundMessage(IMessage message, long msgSeqNum) Stores inbound message.
void	storeOutboundMessage(IMessage message, long msgSeqNum, boolean warmUp) Stores outbound message.

Methods inherited from class java.lang.Object

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

Constructor Detail

TimingSessionStorage

public TimingSessionStorage(SessionStorage storage)

Method Detail

getUnderlyingStorage

public SessionStorage getUnderlyingStorage()

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

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

getOutboundMessages

public List<IMessage> getOutboundMessages(long beginSequenceNumber,
                                          long endSequenceNumber)

Description copied from interface: SessionStorage

Returns outbound messages with the specified sequence number interval. Ends are included.
Warning. This is critical to avoid using the method directly.

Specified by:

getOutboundMessages in interface SessionStorage

Parameters:

beginSequenceNumber - sequence number to begin with

endSequenceNumber - sequence number to end with

Returns:

outbound messages

storeInboundMessage

public void storeInboundMessage(IMessage message,
                                long msgSeqNum)

Description copied from interface: SessionStorage

Stores inbound message.

Specified by:

storeInboundMessage in interface SessionStorage

Parameters:

message - message to store

msgSeqNum - message sequence number

storeOutboundMessage

public void storeOutboundMessage(IMessage message,
                                 long msgSeqNum,
                                 boolean warmUp)

Description copied from interface: SessionStorage

Stores outbound message.

Specified by:

storeOutboundMessage in interface SessionStorage

Parameters:

message - message to store

msgSeqNum - message sequence number

warmUp - indicates whether it is a warmUp message

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

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

getPreviousSeqNo

public long getPreviousSeqNo()

Description copied from interface: SessionStorage

Returns last inbound message sequence number of previous session or 0 if no inbound message is stored.

Specified by:

getPreviousSeqNo in interface SessionStorage

Returns:

inbound sequence number of previous session

setPreviousSeqNo

public void setPreviousSeqNo(long seqNo)

Description copied from interface: SessionStorage

Sets last inbound message sequence number of previous session

Specified by:

setPreviousSeqNo in interface SessionStorage

Parameters:

seqNo - inbound message sequence number of previous session

getUuid

public long getUuid()

Description copied from interface: SessionStorage

Returns Universally Unique Identifier (UUID).

Specified by:

getUuid in interface SessionStorage

Returns:

Universally Unique Identifier (UUID).

setUuid

public void setUuid(long uuid)

Description copied from interface: SessionStorage

Sets Universally Unique Identifier (UUID).

Specified by:

setUuid in interface SessionStorage

Parameters:

uuid - Universally Unique Identifier (UUID)

getPreviousUuid

public long getPreviousUuid()

Description copied from interface: SessionStorage

Returns previous Universally Unique Identifier (UUID).

Specified by:

getPreviousUuid in interface SessionStorage

Returns:

previous Universally Unique Identifier (UUID).

setPreviousUuid

public void setPreviousUuid(long uuid)

Description copied from interface: SessionStorage

Sets previous Universally Unique Identifier (UUID).

Specified by:

setPreviousUuid in interface SessionStorage

Parameters:

uuid - previous Universally Unique Identifier (UUID)

isNegotiated

public boolean isNegotiated()

Description copied from interface: SessionStorage

Returns whether the session is negotiated.

Specified by:

isNegotiated in interface SessionStorage

Returns:

true if the session is negotiated (the Negotiation Response message has been received in reply to the Negotiation message), otherwise false.

setNegotiated

public void setNegotiated(boolean value)

Description copied from interface: SessionStorage

Sets whether the session is negotiated. The session is negotiated when the Negotiation Response message has been received in reply to the Negotiation message.

Specified by:

setNegotiated in interface SessionStorage

Parameters:

value - negotiation status.

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

getMaxStorageSize

public int getMaxStorageSize()

Description copied from interface: SessionStorage

Returns the maximum size of the message storage. The details depend on the selected storage implementation.

Specified by:

getMaxStorageSize in interface SessionStorage

Returns:

maximum size of the message storage

setMaxStorageSize

public void setMaxStorageSize(int maxStorageSize)

Description copied from interface: SessionStorage

Sets the maximum size of the message storage. The details depend on the selected storage implementation.

Specified by:

setMaxStorageSize in interface SessionStorage

Parameters:

maxStorageSize - maximum size of the message storage