com.devexperts.qd.logger
Class LoggedDistributor
java.lang.Object
com.devexperts.qd.logger.LoggedObject
com.devexperts.qd.logger.LoggedDataConsumer
com.devexperts.qd.logger.LoggedDistributor
- All Implemented Interfaces:
- DataConsumer, QDDistributor, QDStatsContainer
public class LoggedDistributor
- extends LoggedDataConsumer
- implements QDDistributor
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
LoggedDistributor
public LoggedDistributor(QDLog log,
java.lang.String name,
QDDistributor delegate,
DataScheme scheme)
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.
The behavior of closed distributor with respect to different actions is undefined, but is guaranteed
to be safe, that is, it will not produce any exceptions or disruptive behavior. In particular, repeated
calls to close
will not produce any further changes to its state.
Methods like processData
may continue to work or may result in no action
depending on implementation. Subscription retrieval may continue to work or may retrieve no subscription.
- Specified by:
close
in interface QDDistributor
getStats
public QDStats getStats()
- Specified by:
getStats
in interface QDStatsContainer