public class Instrument extends Object implements OverflowListener
Modifier and Type | Field and Description |
---|---|
AtomicBoolean |
insideRecovery |
Constructor and Description |
---|
Instrument(String securityDescription,
int incrementQueueSize,
int corridorQueueSize) |
Instrument(String secDesc,
int incrementQueueSize,
int corridorQueueSize,
RecoveryOptions recoveryOptions) |
public AtomicBoolean insideRecovery
public Instrument(String securityDescription, int incrementQueueSize, int corridorQueueSize)
public Instrument(String secDesc, int incrementQueueSize, int corridorQueueSize, RecoveryOptions recoveryOptions)
public String getSecDesc()
public void setSecurityDescription(String secDesc)
public boolean isActive()
public void setActive(boolean active)
public void active()
public boolean isRecovery()
public void setRecovery(boolean recovery)
public RecoveryOptions getRecoveryOptions()
public void setRecoveryOptions(RecoveryOptions recoveryOptions)
public MDChannel getChannel()
public void setChannel(MDChannel channel)
public long getSecurityID()
public void setSecurityID(long securityID)
public boolean isListenForIncrements()
public void setListenForIncrements(boolean listenForIncrements)
public boolean isListenForSnapshots()
public void setListenForSnapshots(boolean listenForSnapshots)
public long getNextSequenceID83()
public void setNextSequenceID83(long nextSequenceID83)
public void incrementNextSequenceID83()
public com.epam.fastadaptor.util.queue.MessageQueue getIncrementalQueue()
public InstrumentListener getInstrumentListener()
public void setInstrumentListener(InstrumentListener instrumentListener)
public long getRevision()
public void setRevision(long revision)
public Corridor getCorridor()
public void resetFirstRecovery()
public void switchOnFirstRecovery()
public boolean isFirstRecovery()
public void resetRecoveryByOverflow()
public boolean isRecoveryByOverflow()
public boolean isForcedRecovery()
public void setThreadRecovery(boolean recovery)
public boolean isThreadRecovery()
public long getLastProcessedSeqNum34()
public void setLastProcessedSeqNum34(long lastProcessedSeqNum34)
public long getRecoveryMsgStartSeqNum()
public void setRecoveryMsgStartSeqNum(long recoveryMsgStartSeqNum)
public long getRecoveryMsgEndSeqNum()
public void setRecoveryMsgEndSeqNum(long recoveryMsgEndSeqNum)
public boolean isHistoryRecovery()
public void setHistoryRecovery(boolean historyRecovery)
public boolean checkNextRptSecNum83(long rptSeqNum)
public void onOverflow()
onOverflow
in interface OverflowListener
public int incrementAndGetSnapshotCyclesCounter()
public void resetSnapshotCyclesCounter()
Copyright © 2000-2017 EPAM Systems. All Rights Reserved.