com.epam.cmefast.impl

Class Instrument

java.lang.Object

com.epam.cmefast.impl.Instrument

All Implemented Interfaces:

OverflowListener

public class Instrument
extends Object
implements OverflowListener

Field Summary

Fields

Modifier and Type	Field and Description
AtomicBoolean	insideRecovery

Constructor Summary

Constructors

Constructor and Description
Instrument(String securityDescription, int incrementQueueSize, int corridorQueueSize)
Instrument(String secDesc, int incrementQueueSize, int corridorQueueSize, RecoveryOptions recoveryOptions)

Method Summary

Modifier and Type	Method and Description
void	active()
boolean	checkNextRptSecNum83(long rptSeqNum)
MDChannel	getChannel()
Corridor	getCorridor()
com.epam.fastadaptor.util.queue.MessageQueue	getIncrementalQueue()
InstrumentListener	getInstrumentListener()
long	getLastProcessedSeqNum34()
long	getNextSequenceID83()
long	getRecoveryMsgEndSeqNum()
long	getRecoveryMsgStartSeqNum()
RecoveryOptions	getRecoveryOptions()
long	getRevision()
String	getSecDesc()
long	getSecurityID()
int	incrementAndGetSnapshotCyclesCounter()
void	incrementNextSequenceID83()
boolean	isActive()
boolean	isFirstRecovery()
boolean	isForcedRecovery()
boolean	isHistoryRecovery()
boolean	isListenForIncrements()
boolean	isListenForSnapshots()
boolean	isRecovery()
boolean	isRecoveryByOverflow()
boolean	isThreadRecovery()
void	onOverflow()
void	resetFirstRecovery()
void	resetRecoveryByOverflow()
void	resetSnapshotCyclesCounter()
void	setActive(boolean active)
void	setChannel(MDChannel channel)
void	setHistoryRecovery(boolean historyRecovery)
void	setInstrumentListener(InstrumentListener instrumentListener)
void	setLastProcessedSeqNum34(long lastProcessedSeqNum34)
void	setListenForIncrements(boolean listenForIncrements)
void	setListenForSnapshots(boolean listenForSnapshots)
void	setNextSequenceID83(long nextSequenceID83)
void	setRecovery(boolean recovery)
void	setRecoveryMsgEndSeqNum(long recoveryMsgEndSeqNum)
void	setRecoveryMsgStartSeqNum(long recoveryMsgStartSeqNum)
void	setRecoveryOptions(RecoveryOptions recoveryOptions)
void	setRevision(long revision)
void	setSecurityDescription(String secDesc)
void	setSecurityID(long securityID)
void	setThreadRecovery(boolean recovery)
void	switchOnFirstRecovery()
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

insideRecovery

public AtomicBoolean insideRecovery

Constructor Detail

Instrument

public Instrument(String securityDescription,
                  int incrementQueueSize,
                  int corridorQueueSize)

Instrument

public Instrument(String secDesc,
                  int incrementQueueSize,
                  int corridorQueueSize,
                  RecoveryOptions recoveryOptions)

Method Detail

getSecDesc

public String getSecDesc()

setSecurityDescription

public void setSecurityDescription(String secDesc)

isActive

public boolean isActive()

setActive

public void setActive(boolean active)

active

public void active()

isRecovery

public boolean isRecovery()

setRecovery

public void setRecovery(boolean recovery)

getRecoveryOptions

public RecoveryOptions getRecoveryOptions()

setRecoveryOptions

public void setRecoveryOptions(RecoveryOptions recoveryOptions)

getChannel

public MDChannel getChannel()

setChannel

public void setChannel(MDChannel channel)

getSecurityID

public long getSecurityID()

setSecurityID

public void setSecurityID(long securityID)

isListenForIncrements

public boolean isListenForIncrements()

setListenForIncrements

public void setListenForIncrements(boolean listenForIncrements)

isListenForSnapshots

public boolean isListenForSnapshots()

setListenForSnapshots

public void setListenForSnapshots(boolean listenForSnapshots)

getNextSequenceID83

public long getNextSequenceID83()

setNextSequenceID83

public void setNextSequenceID83(long nextSequenceID83)

incrementNextSequenceID83

public void incrementNextSequenceID83()

getIncrementalQueue

public com.epam.fastadaptor.util.queue.MessageQueue getIncrementalQueue()

getInstrumentListener

public InstrumentListener getInstrumentListener()

setInstrumentListener

public void setInstrumentListener(InstrumentListener instrumentListener)

getRevision

public long getRevision()

setRevision

public void setRevision(long revision)

getCorridor

public Corridor getCorridor()

resetFirstRecovery

public void resetFirstRecovery()

switchOnFirstRecovery

public void switchOnFirstRecovery()

isFirstRecovery

public boolean isFirstRecovery()

resetRecoveryByOverflow

public void resetRecoveryByOverflow()

isRecoveryByOverflow

public boolean isRecoveryByOverflow()

isForcedRecovery

public boolean isForcedRecovery()

setThreadRecovery

public void setThreadRecovery(boolean recovery)

isThreadRecovery

public boolean isThreadRecovery()

getLastProcessedSeqNum34

public long getLastProcessedSeqNum34()

setLastProcessedSeqNum34

public void setLastProcessedSeqNum34(long lastProcessedSeqNum34)

getRecoveryMsgStartSeqNum

public long getRecoveryMsgStartSeqNum()

setRecoveryMsgStartSeqNum

public void setRecoveryMsgStartSeqNum(long recoveryMsgStartSeqNum)

getRecoveryMsgEndSeqNum

public long getRecoveryMsgEndSeqNum()

setRecoveryMsgEndSeqNum

public void setRecoveryMsgEndSeqNum(long recoveryMsgEndSeqNum)

isHistoryRecovery

public boolean isHistoryRecovery()

setHistoryRecovery

public void setHistoryRecovery(boolean historyRecovery)

toString

public String toString()

Overrides:

toString in class Object

checkNextRptSecNum83

public boolean checkNextRptSecNum83(long rptSeqNum)

onOverflow

public void onOverflow()

Specified by:

onOverflow in interface OverflowListener

incrementAndGetSnapshotCyclesCounter

public int incrementAndGetSnapshotCyclesCounter()

resetSnapshotCyclesCounter

public void resetSnapshotCyclesCounter()