com.devexperts.qd

Interface QDDistributor

All Superinterfaces:

DataConsumer, QDStatsContainer, RecordConsumer

public interface QDDistributor
extends DataConsumer, RecordConsumer, 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.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	QDDistributor.Builder Builder for collector distributors.

Field Summary

Fields inherited from interface com.devexperts.qd.DataConsumer

VOID

Method Summary

Modifier and Type	Method and Description
void	close() Closes this distributor and releases allocated resources in its QDCollector.
RecordProvider	getAddedRecordProvider() Returns record provider that is used to accumulate added subscription.
SubscriptionProvider	getAddedSubscriptionProvider() Deprecated. Use getAddedRecordProvider()
RecordProvider	getRemovedRecordProvider() Returns subscription provider that is used to accumulate removed subscription.
SubscriptionProvider	getRemovedSubscriptionProvider() Deprecated. Use getRemovedRecordProvider()
void	process(RecordSource source) Processes all data from specified record source.
void	processData(DataIterator iterator) Deprecated. Use process(RecordSource).

Methods inherited from interface com.devexperts.qd.stats.QDStatsContainer

getStats

Method Detail

getAddedSubscriptionProvider

SubscriptionProvider getAddedSubscriptionProvider()

Deprecated. Use getAddedRecordProvider()

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.

getAddedRecordProvider

RecordProvider getAddedRecordProvider()

Returns record 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()

Deprecated. Use getRemovedRecordProvider()

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.

getRemovedRecordProvider

RecordProvider getRemovedRecordProvider()

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.

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.

processData

void processData(DataIterator iterator)

Deprecated. Use process(RecordSource).

Processes data from specified data iterator. It is recommended that DataIterator also implements RecordSource interface (RecordBuffer is such default and high-performance implementation), since it yields better performance in certain cases and enables some new features that are not supported with legacy DataIterator implementations.

Specified by:

processData in interface DataConsumer

process

void process(RecordSource source)

Processes all data from specified record source.

Specified by:

process in interface RecordConsumer

Parameters:

source - the record source.