com.devexperts.qd
Interface QDDistributor

All Superinterfaces:
DataConsumer, QDStatsContainer
All Known Implementing Classes:
LoggedDistributor

public interface QDDistributor
extends DataConsumer, QDStatsContainer

The QDDistributor represents an individual data provider in the QDCollector. It is responsible for tracking state of the provider in the collector, including its total subscription, and to provide access point for that provider.


Method Summary
 void close()
          Closes this distributor and releases allocated resources in its QDCollector.
 SubscriptionProvider getAddedSubscriptionProvider()
          Returns subscription provider that is used to accumulate added subscription.
 SubscriptionProvider getRemovedSubscriptionProvider()
          Returns subscription provider that is used to accumulate removed subscription.
 
Methods inherited from interface com.devexperts.qd.DataConsumer
processData
 
Methods inherited from interface com.devexperts.qd.stats.QDStatsContainer
getStats
 

Method Detail

getAddedSubscriptionProvider

SubscriptionProvider getAddedSubscriptionProvider()
Returns subscription provider that is used to accumulate added subscription. On the first invocation of this method all the internal (potentially large) data structures are initialized and the queue of added subscriptions is maintained further on. Don't invoke this method if you don't have to.


getRemovedSubscriptionProvider

SubscriptionProvider getRemovedSubscriptionProvider()
Returns subscription provider that is used to accumulate removed subscription. On the first invocation of this method all the internal (potentially large) data structures are initialized and the queue of removed subscriptions is maintained further on. Don't invoke this method if you don't have to.


close

void close()
Closes this distributor and releases allocated resources in its QDCollector. Closed distributor can not be activated again and shall not be used anymore. Attempt to use closed distributor will result in no action - data will be ignored and subscription retrieval will retrive no subscription.