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.kit |
This package contains default implementations of various QD components which
do not constitute any separate module or subsystem and which can be easily replaced.
|
com.devexperts.qd.ng |
This package contains next-generation interfaces for data and subscription exchange based on
RecordCursor class. |
com.devexperts.qd.qtp |
This package contains interfaces with default implementations required
to create and operate a connection using QTP.
|
com.devexperts.qd.util |
This package contains utility classes which are used by QD, but which do not
depend on QD and which do not constitute any separate module or subsystem.
|
Modifier and Type | Method and Description |
---|---|
QDContract |
QDContract.getContract() |
QDContract |
QDCollector.getContract()
Returns contract that this collector provides.
|
QDContract |
QDCollector.Factory.getContract()
Returns this factory's contract.
|
QDContract |
QDCollector.Builder.getContract()
Returns collector's contract.
|
static QDContract |
QDContract.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static QDContract[] |
QDContract.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
abstract boolean |
QDFilter.accept(QDContract contract,
DataRecord record,
int cipher,
String symbol)
Returns true if this filter accepts a given record and symbol on the specified contract.
|
abstract QDCollector.Builder<?> |
QDFactory.collectorBuilder(QDContract contract)
Creates builder for an collector that has specified contract.
|
QDAgent.Builder |
QDFactory.createVoidAgentBuilder(QDContract contract,
DataScheme scheme)
Creates builder for an agent that is not tied to any particular collector, has no data,
and only keeps track of added and remove subscription.
|
Modifier and Type | Method and Description |
---|---|
boolean |
SymbolSetFilter.accept(QDContract contract,
DataRecord record,
int cipher,
String symbol) |
boolean |
RecordOnlyFilter.accept(QDContract contract,
DataRecord record,
int cipher,
String symbol) |
boolean |
RangeFilter.accept(QDContract contract,
DataRecord record,
int cipher,
String symbol) |
boolean |
PatternFilter.accept(QDContract contract,
DataRecord record,
int cipher,
String symbol) |
boolean |
NotFilter.accept(QDContract contract,
DataRecord record,
int cipher,
String symbol) |
boolean |
HashFilter.accept(QDContract contract,
DataRecord record,
int cipher,
String symbol) |
Modifier and Type | Method and Description |
---|---|
static RecordMode |
RecordMode.addedSubscriptionFor(QDContract contract)
Returns record mode that is used for added subscription of the specified contract.
|
Modifier and Type | Method and Description |
---|---|
QDContract |
MessageType.getContract() |
QDContract |
ChannelShaper.getContract()
Returns contract of the channel.
|
Modifier and Type | Method and Description |
---|---|
Set<QDContract> |
QDEndpoint.getContracts() |
Modifier and Type | Method and Description |
---|---|
QDAgent |
AgentChannels.Owner.createVoidAgent(QDContract contract)
This method is used to create void agent just to keep subscription.
|
static MessageType |
MessageType.forAddSubscription(QDContract contract) |
static MessageType |
MessageType.forData(QDContract contract) |
static MessageType |
MessageType.forRemoveSubscription(QDContract contract) |
QDCollector |
QDEndpoint.getCollector(QDContract contract) |
QDCollector |
DistributorAdapter.getCollector(QDContract contract) |
QDFilter |
AgentChannels.Owner.getPeerFilter(QDContract contract)
When the channel configuration is updated, it will be summarized by logical AND with the filter that is specified
in shaper.
|
boolean |
AgentChannels.processSubscription(RecordSource sub,
QDContract contract,
boolean isSubscriptionAdd)
Processes subscription.
|
boolean |
AgentChannels.Owner.retrieveData(DataProvider dataProvider,
QDContract contract)
Retrieves accumulated data from data provider.
|
Modifier and Type | Method and Description |
---|---|
QDEndpoint.Builder |
QDEndpoint.Builder.withContracts(EnumSet<QDContract> contracts)
Deprecated.
Use
QDEndpoint.Builder.withCollectors(Collection) and it has a more telling name
and wider range of features. |
Constructor and Description |
---|
ChannelShaper(QDContract contract,
Executor subscriptionExecutor)
Creates new channel shaper with specified contract and subscription executor.
|
ChannelShaper(QDContract contract,
Executor subscriptionExecutor,
boolean keepRejected)
Creates new channel shaper with specified contract, subscription executor,
and keep rejected flag.
|
DynamicChannelShaper(QDContract contract,
Executor subscriptionExecutor,
QDFilter subscriptionFilter) |
Constructor and Description |
---|
SubscriptionProcessor(Executor executor,
QDContract contract)
Constructs new subscription processor for the specified executor.
|
Copyright © 2002–2025 Devexperts LLC. All rights reserved.