|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface QDAgent
The QDAgent
represents an individual data consumer in the QDCollector
.
It is responsible for tracking state of the consumer in the collector, including its
total subscription and accumulated data, and to provide access point for that consumer.
Method Summary | |
---|---|
void |
addSubscription(SubscriptionIterator iterator)
Adds specified subscription to this agent's data interest. |
void |
close()
Closes this agent and releases allocated resources in its QDCollector . |
SubscriptionConsumer |
getAddingSubscriptionConsumer()
Returns subscription consumer that can be used to add subscription. |
SubscriptionConsumer |
getRemovingSubscriptionConsumer()
Returns subscription consumer that can be used to remove subscription. |
void |
removeSubscription(SubscriptionIterator iterator)
Removes specified subscription from this agent's data interest. |
void |
setBufferOverflowStrategy(int max_buffer_size,
boolean drop_oldest,
boolean log_overflow)
Sets new strategy for handling of stream and history buffer overflow events. |
void |
setStreamOverflowStrategy(int max_buffer_size,
boolean drop_oldest,
boolean log_overflow)
Deprecated. Use setBufferOverflowStrategy(int, boolean, boolean) } |
void |
setSubscription(SubscriptionIterator iterator)
Sets specified subscription to be this agent's data interest. |
Methods inherited from interface com.devexperts.qd.DataProvider |
---|
retrieveData, setDataListener |
Methods inherited from interface com.devexperts.qd.SubscriptionContainer |
---|
examineSubscription, getSubscriptionSize, isSubscribed |
Methods inherited from interface com.devexperts.qd.stats.QDStatsContainer |
---|
getStats |
Method Detail |
---|
SubscriptionConsumer getAddingSubscriptionConsumer()
addSubscription(com.devexperts.qd.SubscriptionIterator)
method.
SubscriptionConsumer getRemovingSubscriptionConsumer()
removeSubscription(com.devexperts.qd.SubscriptionIterator)
method.
void addSubscription(SubscriptionIterator iterator)
void removeSubscription(SubscriptionIterator iterator)
void setSubscription(SubscriptionIterator iterator)
void close()
QDCollector
.
Closed agent can not be activated again and shall not be used anymore.
Attempt to use closed agent will result in no action - subscription
will be ignored and data retrieval will retrieve no data.
void setStreamOverflowStrategy(int max_buffer_size, boolean drop_oldest, boolean log_overflow)
setBufferOverflowStrategy(int, boolean, boolean)
}
max_buffer_size
- how many records to keep in buffer, default is 1000000drop_oldest
- which record shall be dropped - oldest (true) or newest (false), default is truelog_overflow
- whether overflow event shall be logged or not, default is true
java.lang.IllegalArgumentException
- if max_buffer_size is not a positive integervoid setBufferOverflowStrategy(int max_buffer_size, boolean drop_oldest, boolean log_overflow)
max_buffer_size
- how many records to keep in buffer, default is 1000000drop_oldest
- which record shall be dropped - oldest (true) or newest (false), default is truelog_overflow
- whether overflow event shall be logged or not, default is true
java.lang.IllegalArgumentException
- if max_buffer_size is not a positive integer
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |