com.epam.bovespafast.impl

Class Instrument

java.lang.Object

com.epam.bovespafast.impl.Instrument

All Implemented Interfaces:

OverflowListener

public class Instrument
extends Object
implements OverflowListener

The instrument representation.

Constructor Summary

Constructors

Constructor and Description
Instrument(String symbol, ChannelContext channelContext)
Instrument(String symbol, int queueSize, ChannelContext channelContext)
Instrument(String symbol, String secId, ChannelContext channelContext)
Instrument(String symbol, String secId, int queueSize, ChannelContext channelContext)
Instrument(String symbol, String secId, String secGroup, ChannelContext channelContext)

Method Summary

Modifier and Type	Method and Description
void	activate()
void	checkAndNotifyIfPrevMessageEnd(long newSeqNum34)
void	clearMessageQueue()
boolean	equals(Object o)
int	getCircleNumb()
long	getFirstSeqNumInQueue()
protected InstrumentListener	getInstrumentListener()
int	getMessageSynchronizeQueue()
long	getNextProcessedRptSeqNum83()
long	getProcessedRptSeqNum83()
long	getProcessedSeqNum34()
long	getQueuedEntriesCount()
long	getRecoveryMsgEndSeqNum34()
long	getRecoveryMsgStartSeqNum34()
String	getSecGroup()
String	getSecId()
State	getState()
String	getSymbol()
int	hashCode()
void	incrementProcessedRptSeqNum83()
boolean	isActive()
boolean	isExpectedRptSeqNum83(long incomingRptSeqNum)
boolean	isGrRptSeqNum83(long incomingSeqNum)
boolean	isNeedSnapshotRecovery()
boolean	isRecovered(long seqNum34)
boolean	isSnapshotReceivedFlag()
long	jumpToSeqNumAndReturnLastRPT(long incomingSeqNum)
void	notifyNextCircle()
void	onIncrementMessageEnd(long seqNum34)
void	onOverflow()
void	processIncrement(GroupEntry entry, InstrumentMessageProcessor incrementMessageProcessor)
boolean	processMessageInQueue(IncrementListener messageListener) Try to process all unhandled messages (increments and ?)
void	processSnapshot(com.epam.fix.message.FIXFieldList message, InstrumentMessageProcessor snapMessageProcessor, InstrumentMessageProcessor incrementMessageProcessor)
void	putToQueue(int rptSeqNum83, com.epam.fastadaptor.util.queue.MessageHolder messageHolder)
void	resetCircleNumb()
void	resetSnapshotReceivedFlag()
void	setActive(boolean active)
void	setLastFinishedSeqNum34(long lastFinishedSeqNum)
void	setNeedSnapshotRecovery(boolean needSnapshotRecovery)
void	setProcessedRptSeqNum83(long processedRptSeqNum83)
void	setProcessedSeqNum34(long processedSeqNum34)
void	setRecoveryMsgEndSeqNum34(long msgEndSeqNum34)
void	setRecoveryMsgStartSeqNum34(long msgStartSeqNum34)
void	setSecGroup(String secGroup)
void	setSecId(String secId)
void	setSnapshotReceivedFlag()
void	setState(State state)
void	setSymbol(String symbol)
protected void	stopRecovery()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

Instrument

public Instrument(String symbol,
                  ChannelContext channelContext)

Instrument

public Instrument(String symbol,
                  int queueSize,
                  ChannelContext channelContext)

Instrument

public Instrument(String symbol,
                  String secId,
                  ChannelContext channelContext)

Instrument

public Instrument(String symbol,
                  String secId,
                  String secGroup,
                  ChannelContext channelContext)

Instrument

public Instrument(String symbol,
                  String secId,
                  int queueSize,
                  ChannelContext channelContext)

Method Detail

getSecId

public String getSecId()

setSecId

public void setSecId(String secId)

getSymbol

public String getSymbol()

setSymbol

public void setSymbol(String symbol)

getSecGroup

public String getSecGroup()

setSecGroup

public void setSecGroup(String secGroup)

isActive

public boolean isActive()

activate

public void activate()

setActive

public void setActive(boolean active)

getProcessedRptSeqNum83

public long getProcessedRptSeqNum83()

setProcessedRptSeqNum83

public void setProcessedRptSeqNum83(long processedRptSeqNum83)

getNextProcessedRptSeqNum83

public long getNextProcessedRptSeqNum83()

getProcessedSeqNum34

public long getProcessedSeqNum34()

setProcessedSeqNum34

public void setProcessedSeqNum34(long processedSeqNum34)

setState

public void setState(State state)

getState

public State getState()

incrementProcessedRptSeqNum83

public void incrementProcessedRptSeqNum83()

isExpectedRptSeqNum83

public boolean isExpectedRptSeqNum83(long incomingRptSeqNum)

isGrRptSeqNum83

public boolean isGrRptSeqNum83(long incomingSeqNum)

getMessageSynchronizeQueue

public int getMessageSynchronizeQueue()

getRecoveryMsgStartSeqNum34

public long getRecoveryMsgStartSeqNum34()

setRecoveryMsgStartSeqNum34

public void setRecoveryMsgStartSeqNum34(long msgStartSeqNum34)

getRecoveryMsgEndSeqNum34

public long getRecoveryMsgEndSeqNum34()

setRecoveryMsgEndSeqNum34

public void setRecoveryMsgEndSeqNum34(long msgEndSeqNum34)

processIncrement

public void processIncrement(GroupEntry entry,
                             InstrumentMessageProcessor incrementMessageProcessor)

processSnapshot

public void processSnapshot(com.epam.fix.message.FIXFieldList message,
                            InstrumentMessageProcessor snapMessageProcessor,
                            InstrumentMessageProcessor incrementMessageProcessor)

stopRecovery

protected void stopRecovery()

processMessageInQueue

public boolean processMessageInQueue(IncrementListener messageListener)

Try to process all unhandled messages (increments and ?)

Parameters:

messageListener - to process messages

Returns:

false	if we have no message to process
true	elsewhere

TODO (perhaps)

false	if we don`t process all messages
true	if we process all messages

getFirstSeqNumInQueue

public long getFirstSeqNumInQueue()

getQueuedEntriesCount

public long getQueuedEntriesCount()

clearMessageQueue

public void clearMessageQueue()

putToQueue

public void putToQueue(int rptSeqNum83,
                       com.epam.fastadaptor.util.queue.MessageHolder messageHolder)

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object

onOverflow

public void onOverflow()

Specified by:

onOverflow in interface OverflowListener

jumpToSeqNumAndReturnLastRPT

public long jumpToSeqNumAndReturnLastRPT(long incomingSeqNum)

isNeedSnapshotRecovery

public boolean isNeedSnapshotRecovery()

setNeedSnapshotRecovery

public void setNeedSnapshotRecovery(boolean needSnapshotRecovery)

notifyNextCircle

public void notifyNextCircle()

isSnapshotReceivedFlag

public boolean isSnapshotReceivedFlag()

setSnapshotReceivedFlag

public void setSnapshotReceivedFlag()

resetSnapshotReceivedFlag

public void resetSnapshotReceivedFlag()

resetCircleNumb

public void resetCircleNumb()

getCircleNumb

public int getCircleNumb()

isRecovered

public boolean isRecovered(long seqNum34)

checkAndNotifyIfPrevMessageEnd

public void checkAndNotifyIfPrevMessageEnd(long newSeqNum34)

onIncrementMessageEnd

public void onIncrementMessageEnd(long seqNum34)

setLastFinishedSeqNum34

public void setLastFinishedSeqNum34(long lastFinishedSeqNum)

getInstrumentListener

protected InstrumentListener getInstrumentListener()