|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.devexperts.qd.logger.LoggedObject
com.devexperts.qd.logger.LoggedCollector
com.devexperts.qd.logger.LoggedTicker
public class LoggedTicker
Field Summary |
---|
Fields inherited from class com.devexperts.qd.logger.LoggedObject |
---|
log, name |
Constructor Summary | |
---|---|
LoggedTicker(QDLog log,
java.lang.String name,
QDTicker delegate)
|
Method Summary | |
---|---|
boolean |
examineData(DataVisitor visitor)
Examines all stored data via specified data visitor. |
void |
getData(RecordCursor.Owner owner,
DataRecord record,
int cipher,
java.lang.String symbol)
Gets all data for the specified record, cipher, and symbol in a single call and sets RecordCursor via caller-provided
RecordCursor.Owner to the
corresponding memory storage in read-only mode. |
void |
getData(RecordCursor cursor,
DataRecord record,
int cipher,
java.lang.String symbol)
Gets all data for the specified record, cipher, and symbol in a single call and returns it via caller-provided RecordCursor . |
int |
getInt(DataIntField field,
int cipher,
java.lang.String symbol)
Returns current value of specified Int-field. |
java.lang.Object |
getObj(DataObjField field,
int cipher,
java.lang.String symbol)
Returns current value of specified Obj-field. |
boolean |
isAvailable(DataRecord record,
int cipher,
java.lang.String symbol)
Determines if value of specified record is available. |
boolean |
isStoreEverything()
Returns status of "store everything" mode. |
void |
remove(RecordSource source)
Removes the corresponding records from the underlying ticker storage. |
void |
setStoreEverything(boolean store_everything)
Sets "store everything" mode (disabled by default). |
void |
setStoreEverythingFilter(SubscriptionFilter filter)
Sets filter that is used for "store everything" mode. |
Methods inherited from class com.devexperts.qd.logger.LoggedCollector |
---|
createAgent, createAgent, createDistributor, createDistributor, examineSubscription, getContract, getScheme, getStats, getSubscriptionSize, getSymbol, isSubscribed, setErrorHandler |
Methods inherited from class com.devexperts.qd.logger.LoggedObject |
---|
child, debug, toString |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface com.devexperts.qd.QDCollector |
---|
createAgent, createAgent, createDistributor, createDistributor, getContract, getScheme, getSymbol, setErrorHandler |
Methods inherited from interface com.devexperts.qd.SubscriptionContainer |
---|
examineSubscription, getSubscriptionSize, isSubscribed |
Methods inherited from interface com.devexperts.qd.stats.QDStatsContainer |
---|
getStats |
Constructor Detail |
---|
public LoggedTicker(QDLog log, java.lang.String name, QDTicker delegate)
Method Detail |
---|
public boolean isStoreEverything()
QDTicker
isStoreEverything
in interface QDTicker
QDTicker.setStoreEverything(boolean)
public void setStoreEverything(boolean store_everything)
QDTicker
processData
stores everything into underlying storage regardless of subscription (by default only records that are
subscribed on are being stored). When subscription is removed records are not removed from storage
(by default they are). Only records that match specified filter
are subject to this mode (all records by default).
setStoreEverything
in interface QDTicker
public void setStoreEverythingFilter(SubscriptionFilter filter)
QDTicker
null
(default)
to turn off filtering and store all records when "store everything" mode is on.
setStoreEverythingFilter
in interface QDTicker
QDTicker.setStoreEverything(boolean)
public boolean isAvailable(DataRecord record, int cipher, java.lang.String symbol)
QDTicker
isAvailable
in interface QDTicker
public int getInt(DataIntField field, int cipher, java.lang.String symbol)
QDTicker
getInt
in interface QDTicker
public java.lang.Object getObj(DataObjField field, int cipher, java.lang.String symbol)
QDTicker
getObj
in interface QDTicker
public void getData(RecordCursor cursor, DataRecord record, int cipher, java.lang.String symbol)
QDTicker
RecordCursor
.
getData
in interface QDTicker
public void getData(RecordCursor.Owner owner, DataRecord record, int cipher, java.lang.String symbol)
QDTicker
RecordCursor
via caller-provided
RecordCursor.Owner
to the
corresponding memory storage in read-only mode. This way, any fields
can be retried from ticker without requiring any actual data copy or memory allocation.
getData
in interface QDTicker
public boolean examineData(DataVisitor visitor)
QDTicker
true
if some data was not examined or
false
if everything was examined.
examineData
in interface QDTicker
public void remove(RecordSource source)
QDTicker
QDTicker.isAvailable(com.devexperts.qd.DataRecord, int, java.lang.String)
will become false
for all removed records.
This method is designed to facilitate cleanup of stale data. Intended pattern
for this method is to call QDTicker.examineData(com.devexperts.qd.DataVisitor)
, store stale records to be removed
into RecordBuffer
and use QDTicker.remove(com.devexperts.qd.ng.RecordSource)
for them.
remove
in interface QDTicker
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |