com.devexperts.qd.logger
Class LoggedDistributor

java.lang.Object
  extended by com.devexperts.qd.logger.LoggedObject
      extended by com.devexperts.qd.logger.LoggedDataConsumer
          extended by com.devexperts.qd.logger.LoggedDistributor
All Implemented Interfaces:
DataConsumer, QDDistributor, QDStatsContainer

public class LoggedDistributor
extends LoggedDataConsumer
implements QDDistributor


Field Summary
 
Fields inherited from class com.devexperts.qd.logger.LoggedObject
log, name
 
Constructor Summary
LoggedDistributor(QDLog log, java.lang.String name, QDDistributor delegate, DataScheme scheme)
           
 
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.
 QDStats getStats()
           
 
Methods inherited from class com.devexperts.qd.logger.LoggedDataConsumer
processData
 
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.DataConsumer
processData
 

Constructor Detail

LoggedDistributor

public LoggedDistributor(QDLog log,
                         java.lang.String name,
                         QDDistributor delegate,
                         DataScheme scheme)
Method Detail

getAddedSubscriptionProvider

public SubscriptionProvider getAddedSubscriptionProvider()
Description copied from interface: QDDistributor
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.

Specified by:
getAddedSubscriptionProvider in interface QDDistributor

getRemovedSubscriptionProvider

public SubscriptionProvider getRemovedSubscriptionProvider()
Description copied from interface: QDDistributor
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.

Specified by:
getRemovedSubscriptionProvider in interface QDDistributor

close

public void close()
Description copied from interface: QDDistributor
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.

Specified by:
close in interface QDDistributor

getStats

public QDStats getStats()
Specified by:
getStats in interface QDStatsContainer