|
|||||||||
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
public class LoggedCollector
Field Summary |
---|
Fields inherited from class com.devexperts.qd.logger.LoggedObject |
---|
log, name |
Constructor Summary | |
---|---|
LoggedCollector(QDLog log,
java.lang.String name,
QDCollector delegate)
|
Method Summary | |
---|---|
QDAgent |
createAgent(SubscriptionFilter filter)
Creates new agent with specified subscription filter. |
QDAgent |
createAgent(SubscriptionFilter filter,
java.lang.String key_properties)
|
QDDistributor |
createDistributor(SubscriptionFilter filter)
Creates new distributor with specified subscription filter. |
QDDistributor |
createDistributor(SubscriptionFilter filter,
java.lang.String key_properties)
|
boolean |
examineSubscription(SubscriptionVisitor visitor)
Examines subscription and passes it to the visitor. |
QDContract |
getContract()
Retruns contract that this collector provides. |
DataScheme |
getScheme()
Returns data scheme used by this QD component. |
QDStats |
getStats()
|
int |
getSubscriptionSize()
Returns subscription size in terms of (record, symbol) pairs. |
java.lang.String |
getSymbol(char[] chars,
int offset,
int length)
|
boolean |
isSubscribed(DataRecord record,
int cipher,
java.lang.String symbol,
long time)
Returns true if subscribed to the corresponding record and symbol with the
corresponding time. |
void |
setErrorHandler(QDErrorHandler error_handler)
Sets errors handler for all errors that are happening during notification of agents and distributors. |
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 |
Constructor Detail |
---|
public LoggedCollector(QDLog log, java.lang.String name, QDCollector delegate)
Method Detail |
---|
public DataScheme getScheme()
QDCollector
getScheme
in interface QDCollector
public QDContract getContract()
QDCollector
getContract
in interface QDCollector
public QDAgent createAgent(SubscriptionFilter filter)
QDCollector
null
to use no filter.
createAgent
in interface QDCollector
public QDAgent createAgent(SubscriptionFilter filter, java.lang.String key_properties)
createAgent
in interface QDCollector
public QDDistributor createDistributor(SubscriptionFilter filter)
QDCollector
null
to use no filter.
createDistributor
in interface QDCollector
public QDDistributor createDistributor(SubscriptionFilter filter, java.lang.String key_properties)
createDistributor
in interface QDCollector
public QDStats getStats()
getStats
in interface QDStatsContainer
public boolean isSubscribed(DataRecord record, int cipher, java.lang.String symbol, long time)
SubscriptionContainer
true
if subscribed to the corresponding record and symbol with the
corresponding time. Non-historic (stream and ticker) QD ignores time parameter.
Note: Check by time in history is not guaranteed yet
(may transiently give wrong result), because it performs unsynchronized
read on two ints to get time from internal data structure.
In history it is guaranteed to work properly only when time parameter is set to
Long.MAX_VALUE
.
isSubscribed
in interface SubscriptionContainer
public boolean examineSubscription(SubscriptionVisitor visitor)
SubscriptionContainer
true
if not all subscription was examined or
false
otherwise.
Note: Visited subscription time in history is not guaranteed yet (may transiently give wrong result), because it performs unsynchronized read on two ints to get time from internal data structure.
examineSubscription
in interface SubscriptionContainer
public int getSubscriptionSize()
SubscriptionContainer
getSubscriptionSize
in interface SubscriptionContainer
public void setErrorHandler(QDErrorHandler error_handler)
QDCollector
DataScheme.getService(java.lang.Class)
method
and QDErrorHandler.DEFAULT
is used if no override is found.
setErrorHandler
in interface QDCollector
public java.lang.String getSymbol(char[] chars, int offset, int length)
getSymbol
in interface QDCollector
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |