Package | Description |
---|---|
com.devexperts.qd |
This package contains basic interfaces and other API elements of QD system
which shall be sufficient for the client application programmer.
|
com.devexperts.qd.qtp |
This package contains interfaces with default implementations required
to create and operate a connection using QTP.
|
Modifier and Type | Interface and Description |
---|---|
static interface |
QDCollector.Builder<T extends QDCollector>
Builder for collectors.
|
Modifier and Type | Interface and Description |
---|---|
interface |
QDHistory
The
QDHistory represents a history-view of the data. |
interface |
QDStream
The
QDStream represents a stream-view of the data. |
interface |
QDTicker
The
QDTicker represents a ticker-view of the data. |
Modifier and Type | Method and Description |
---|---|
QDCollector |
QDContract.createCollector(QDFactory factory,
QDCollector.Builder<?> builder) |
QDCollector |
QDCollector.Factory.createCollector(QDFactory factory,
QDCollector.Builder<?> builder)
Creates collector instance using a given base factory, data scheme, and stats.
|
Modifier and Type | Method and Description |
---|---|
Class<? extends QDCollector> |
QDContract.getInterface() |
Modifier and Type | Method and Description |
---|---|
QDCollector |
ChannelShaper.getCollector()
Returns collector currently used by the channel.
|
QDCollector |
QDEndpoint.getCollector(QDContract contract) |
QDCollector |
DistributorAdapter.getCollector(QDContract contract) |
QDCollector[] |
MessageAdapter.AbstractFactory.getCollectors() |
Modifier and Type | Method and Description |
---|---|
Collection<QDCollector> |
QDEndpoint.getCollectors() |
Modifier and Type | Method and Description |
---|---|
QDEndpoint |
QDEndpoint.addCollector(QDCollector collector)
This method is used only for the endpoint,
which was created with
QDEndpoint.QDEndpoint(String, DataScheme, QDStats, List, boolean, boolean) . |
QDEndpoint |
QDEndpoint.addCollectors(QDCollector... collectors)
This method is used only for the endpoint,
which was created with
QDEndpoint.QDEndpoint(String, DataScheme, QDStats, List, boolean, boolean) . |
void |
OutputStreamComposer.composeCollector(QDCollector collector)
Composes specified collector.
|
protected QDAgent |
AgentAdapter.createAgent(QDCollector collector,
SubscriptionFilter filter,
String keyProperties)
This method is used internally by agent adapter to create agent for the corresponding
collector, filter, and keyProperties when the corresponding subscription arrives for a first time.
|
protected QDAgent.Builder |
AgentAdapter.createAgentBuilder(QDCollector collector,
SubscriptionFilter filter,
String keyProperties) |
protected QDDistributor |
DistributorAdapter.createDistributor(QDCollector collector,
SubscriptionFilter filter,
String keyProperties)
This method is used internally by distributor adapter to create agent for the corresponding
collector, filter, and keyProperties from this adapter's constructor.
|
static DataScheme |
MessageAdapter.getCommonScheme(QDCollector c1,
QDCollector c2,
QDCollector c3)
Returns common data scheme or throws IllegalArgumentException.
|
void |
ChannelShaper.setCollector(QDCollector collector)
Sets collector for the channel.
|
Constructor and Description |
---|
ChannelShaper(Executor subscriptionExecutor,
QDCollector collector,
SubscriptionFilter subscriptionFilter,
RecordFilter dataFilter)
|
Factory(QDCollector collector) |
Factory(QDCollector collector) |
Copyright © 2002-2018 Devexperts LLC. All Rights Reserved.