- abortMessageAndRethrow(Throwable) - Method in class com.devexperts.qd.qtp.AbstractQTPComposer
-
- abs(int) - Static method in class com.devexperts.qd.util.Decimal
-
- AbstractConnectionHandler<C extends AbstractMessageConnector> - Class in com.devexperts.qd.qtp
-
- AbstractConnectionHandler(C) - Constructor for class com.devexperts.qd.qtp.AbstractConnectionHandler
-
- AbstractConnectionHandler.Factory - Interface in com.devexperts.qd.qtp
-
- AbstractDataField - Class in com.devexperts.qd.kit
-
- AbstractDataIntField - Class in com.devexperts.qd.kit
-
- AbstractDataObjField - Class in com.devexperts.qd.kit
-
- AbstractFactory(QDTicker, QDStream, QDHistory, SubscriptionFilter) - Constructor for class com.devexperts.qd.qtp.MessageAdapter.AbstractFactory
-
Creates new factory.
- AbstractFactory(QDEndpoint, SubscriptionFilter) - Constructor for class com.devexperts.qd.qtp.MessageAdapter.AbstractFactory
-
- AbstractMessageConnector - Class in com.devexperts.qd.qtp
-
- AbstractMessageConnector(ApplicationConnectionFactory) - Constructor for class com.devexperts.qd.qtp.AbstractMessageConnector
-
Constructs new abstract message connector.
- AbstractMessageConnector.Joinable - Interface in com.devexperts.qd.qtp
-
- AbstractMessageVisitor - Class in com.devexperts.qd.qtp
-
- AbstractMessageVisitor() - Constructor for class com.devexperts.qd.qtp.AbstractMessageVisitor
-
- AbstractQTPComposer - Class in com.devexperts.qd.qtp
-
Base class for classes that compose QTP messages data into a byte stream in some format.
- AbstractQTPComposer(DataScheme, boolean) - Constructor for class com.devexperts.qd.qtp.AbstractQTPComposer
-
Constructs composer.
- AbstractQTPParser - Class in com.devexperts.qd.qtp
-
Base class for classes that parse QTP messages data from byte stream in some format.
- AbstractQTPParser(DataScheme) - Constructor for class com.devexperts.qd.qtp.AbstractQTPParser
-
Constructs parser with a specified scheme.
- AbstractRecordProvider - Class in com.devexperts.qd.ng
-
- AbstractRecordProvider() - Constructor for class com.devexperts.qd.ng.AbstractRecordProvider
-
- AbstractRecordSink - Class in com.devexperts.qd.ng
-
- AbstractRecordSink() - Constructor for class com.devexperts.qd.ng.AbstractRecordSink
-
- AbstractServerConnector - Class in com.devexperts.qd.qtp
-
- AbstractServerConnector(ApplicationConnectionFactory) - Constructor for class com.devexperts.qd.qtp.AbstractServerConnector
-
Constructs new abstract message connector.
- accept(QDContract, DataRecord, int, String) - Method in class com.devexperts.qd.kit.HashFilter
-
- accept(QDContract, DataRecord, int, String) - Method in class com.devexperts.qd.kit.NotFilter
-
- accept(QDContract, DataRecord, int, String) - Method in class com.devexperts.qd.kit.PatternFilter
-
- accept(QDContract, DataRecord, int, String) - Method in class com.devexperts.qd.kit.RangeFilter
-
- accept(QDContract, DataRecord, int, String) - Method in class com.devexperts.qd.kit.RecordOnlyFilter
-
- accept(QDContract, DataRecord, int, String) - Method in class com.devexperts.qd.kit.SymbolSetFilter
-
- accept(RecordCursor) - Method in interface com.devexperts.qd.ng.RecordFilter
-
Returns true if record pointed to by this cursor is accepted.
- accept(QDContract, DataRecord, int, String) - Method in class com.devexperts.qd.QDFilter
-
Returns true if this filter accepts a given record and symbol on the specified contract.
- accept(RecordCursor) - Method in class com.devexperts.qd.QDFilter
-
- accept(RecordCursor) - Method in class com.devexperts.qd.qtp.fieldreplacer.FieldReplacersCache
-
- acceptCode(long) - Method in class com.devexperts.qd.kit.RangeFilter
-
- acceptor - Variable in class com.devexperts.qd.qtp.socket.ServerSocketConnector
-
- acceptRecord(DataRecord) - Method in class com.devexperts.qd.kit.RecordOnlyFilter
-
- acceptRecord(DataRecord, int, String) - Method in class com.devexperts.qd.QDFilter
-
- acceptRecord(DataRecord, int, String) - Method in interface com.devexperts.qd.SubscriptionFilter
-
Determines if specified record shall be processed by corresponding subsystem.
- acceptString(String) - Method in class com.devexperts.qd.kit.RangeFilter
-
- active - Variable in class com.devexperts.qd.qtp.AbstractServerConnector
-
- adapterClosed(MessageAdapter) - Method in interface com.devexperts.qd.qtp.MessageAdapter.CloseListener
-
- add(DataRecord, int, String) - Method in class com.devexperts.qd.ng.RecordBuffer
-
Returns write cursor at the current limit and advances limit.
- add(RecordCursor) - Method in class com.devexperts.qd.ng.RecordBuffer
-
Adds a record to this buffer from the specified
RecordCursor
and returns write cursor to the recently added record.
- add(int, int) - Static method in class com.devexperts.qd.util.Decimal
-
Adds two specified decimals and returns result as decimal.
- add(int, String) - Method in class com.devexperts.qd.util.SymbolSet
-
- add(int, char[], int, int) - Method in class com.devexperts.qd.util.SymbolSet
-
- addAll(RecordSource) - Method in class com.devexperts.qd.ng.RecordBuffer
-
- addAll(RecordSource, SubscriptionFilter) - Method in class com.devexperts.qd.ng.RecordBuffer
-
- addAll(SymbolSet) - Method in class com.devexperts.qd.util.SymbolSet
-
- addBytes(byte[], int, int) - Method in class com.devexperts.qd.qtp.ByteArrayParser
-
Deprecated.
Adds specified bytes to the end of byte array buffer.
- addChild(QDStats) - Method in class com.devexperts.qd.stats.QDStats
-
- addClosedConnectionStats(ConnectionStats) - Method in class com.devexperts.qd.qtp.AbstractMessageConnector
-
- addClosedStats(QDStats) - Method in class com.devexperts.qd.stats.QDStats
-
- addCollector(QDCollector) - Method in class com.devexperts.qd.qtp.QDEndpoint
-
Deprecated.
- addCollectors(QDCollector...) - Method in class com.devexperts.qd.qtp.QDEndpoint
-
Deprecated.
- addConnectors(Collection<MessageConnector>) - Method in class com.devexperts.qd.qtp.QDEndpoint
-
- addConnectorsImpl(Collection<MessageConnector>) - Method in class com.devexperts.qd.qtp.QDEndpoint
-
- addDataAndCompactIfNeeded(RecordCursor) - Method in class com.devexperts.qd.ng.RecordBuffer
-
- addedSubscriptionFor(QDContract) - Static method in class com.devexperts.qd.ng.RecordMode
-
Returns record mode that is used for added subscription of the specified contract.
- addFieldAlias(String, String) - Method in class com.devexperts.qd.kit.DefaultRecord
-
- addHandler(SocketHandler) - Method in class com.devexperts.qd.qtp.socket.ServerSocketConnector
-
- addMask(long) - Method in class com.devexperts.qd.qtp.MessageAdapter
-
Adds bytes from argument mask to internal mask and notifies
listeners if internal mask changed.
- addMBean(String, Object) - Method in class com.devexperts.qd.stats.QDStats
-
- addMessageConnectionListener(MessageConnectorListener) - Method in class com.devexperts.qd.qtp.QDEndpoint
-
- addMessageConnectorListener(MessageConnectorListener) - Method in class com.devexperts.qd.qtp.AbstractMessageConnector
-
- addMessageConnectorListener(MessageConnectorListener) - Method in interface com.devexperts.qd.qtp.MessageConnector
-
Adds the specified
listener
to this message connector.
- addMessageConnectorListener(Collection<? extends MessageConnector>, MessageConnectorListener) - Static method in class com.devexperts.qd.qtp.MessageConnectors
-
- addPlugin(QDEndpoint.Plugin) - Method in class com.devexperts.qd.qtp.QDEndpoint
-
- addReceive(MessageDescriptor) - Method in class com.devexperts.qd.qtp.ProtocolDescriptor
-
- address - Variable in class com.devexperts.qd.qtp.AbstractConnectionHandler
-
- address - Variable in class com.devexperts.qd.qtp.socket.ClientSocketConnector
-
- AddressSyntaxException - Exception in com.devexperts.qd.qtp
-
- AddressSyntaxException(String) - Constructor for exception com.devexperts.qd.qtp.AddressSyntaxException
-
- AddressSyntaxException(String, Throwable) - Constructor for exception com.devexperts.qd.qtp.AddressSyntaxException
-
- addSend(MessageDescriptor) - Method in class com.devexperts.qd.qtp.ProtocolDescriptor
-
- addSubscription(SubscriptionIterator) - Method in interface com.devexperts.qd.QDAgent
-
- addSubscription(RecordSource) - Method in interface com.devexperts.qd.QDAgent
-
Adds specified subscription to this agent's data interest.
- addSubscriptionPart(RecordSource, int) - Method in interface com.devexperts.qd.QDAgent
-
Adds part of a specified subscription to this agent's data interest.
- addUpdateListener(QDFilter.UpdateListener) - Method in class com.devexperts.qd.QDFilter
-
- addUpdateListener(QDFilter.UpdateListener) - Method in class com.devexperts.qd.QDFilter.Updated
-
- addValues(QDStats.SValue, boolean, long[]) - Method in class com.devexperts.qd.stats.QDStats
-
- AGENT - Static variable in class com.devexperts.qd.stats.QDStats.SType
-
- AGENT_DATA - Static variable in class com.devexperts.qd.stats.QDStats.SType
-
- AGENT_SUB - Static variable in class com.devexperts.qd.stats.QDStats.SType
-
- AgentAdapter - Class in com.devexperts.qd.qtp
-
The AgentAdapter
adapts agent side of QD to message API.
- AgentAdapter(QDEndpoint, QDTicker, QDStream, QDHistory, SubscriptionFilter, QDFilter, QDStats) - Constructor for class com.devexperts.qd.qtp.AgentAdapter
-
Creates new agent adapter for specified endpoints, ticker, stream, history, filter and stats.
- AgentAdapter(QDEndpoint, QDTicker, QDStream, QDHistory, SubscriptionFilter, QDStats) - Constructor for class com.devexperts.qd.qtp.AgentAdapter
-
Deprecated.
- AgentAdapter(QDTicker, QDStream, QDHistory, SubscriptionFilter, QDStats) - Constructor for class com.devexperts.qd.qtp.AgentAdapter
-
Deprecated.
- AgentAdapter(DataScheme, QDStats) - Constructor for class com.devexperts.qd.qtp.AgentAdapter
-
Creates new agent adapter for specified scheme and stats.
- AgentAdapter.Factory - Class in com.devexperts.qd.qtp
-
The factory for agent side of an QD.
- AgentAdapterChannels - Class in com.devexperts.qd.qtp
-
- AgentAdapterChannels(ChannelDescription[], AgentAdapter) - Constructor for class com.devexperts.qd.qtp.AgentAdapterChannels
-
- AgentAdapterChannels(ChannelDescription[], AgentAdapter.Factory) - Constructor for class com.devexperts.qd.qtp.AgentAdapterChannels
-
- agentBuilder() - Method in interface com.devexperts.qd.QDCollector
-
Returns a builder that can be configured to
build
custom agents.
- AgentChannels - Class in com.devexperts.qd.qtp
-
The AgentChannels class represents a collection of agent channels, each associated with a QDAgent.
- AgentChannels(AgentChannels.Owner, Collection<ChannelShaper>) - Constructor for class com.devexperts.qd.qtp.AgentChannels
-
- AgentChannels.Owner - Interface in com.devexperts.qd.qtp
-
The Owner interface represents the owner of the agent channels.
- ALL_DATA - Static variable in class com.devexperts.qd.qtp.auth.BasicChannelShaperFactory
-
- allocate(RecordCursor) - Static method in class com.devexperts.qd.ng.RecordCursor
-
Allocates RecordCursor
that points to a freshly allocated storage with a copy of
data from a given source.
- allocate(DataRecord, int, String) - Static method in class com.devexperts.qd.ng.RecordCursor
-
Allocates writable RecordCursor
that points to a freshly allocated storage for a given record's
integer and object field values and also sets symbol.
- allocate(DataRecord, int, String, RecordMode) - Static method in class com.devexperts.qd.ng.RecordCursor
-
Allocates writable RecordCursor
that points to a freshly allocated storage for a given record's
integer and object field values using a specified mode and also sets symbol.
- allocate(DataRecord, String) - Static method in class com.devexperts.qd.ng.RecordCursor
-
Allocates writable RecordCursor
that points to a freshly allocated storage for a given record's
integer and object field values and also sets symbol.
- allocate(DataRecord, String, RecordMode) - Static method in class com.devexperts.qd.ng.RecordCursor
-
Allocates writable RecordCursor
that points to a freshly allocated storage for a given record's
integer and object field values using a specified mode and also sets symbol.
- allocateOwner(RecordCursor) - Static method in class com.devexperts.qd.ng.RecordCursor
-
Allocates RecordCursor.Owner
that points to a freshly allocated storage with a copy of
data from a given source.
- allocateOwner(DataRecord, int, String) - Static method in class com.devexperts.qd.ng.RecordCursor
-
Allocates writable RecordCursor.Owner
that points to a freshly allocated storage for a given record's
integer and object field values and also sets symbol.
- allocateOwner(DataRecord, int, String, RecordMode) - Static method in class com.devexperts.qd.ng.RecordCursor
-
Allocates writable RecordCursor.Owner
that points to a freshly allocated storage for a given record's
integer and object field values using a specified mode and also sets symbol.
- allocateOwner(DataRecord) - Static method in class com.devexperts.qd.ng.RecordCursor
-
Allocates writable RecordCursor.Owner
that points to a freshly allocated storage for a given record's
integer and object field values.
- allocateOwner(DataRecord, RecordMode) - Static method in class com.devexperts.qd.ng.RecordCursor
-
Allocates writable RecordCursor.Owner
that points to a freshly allocated storage for a given record's
integer and object field values using a specified mode.
- allocateOwner() - Static method in class com.devexperts.qd.ng.RecordCursor
-
Returns newly allocated record cursor owner object.
- ANY - Static variable in class com.devexperts.qd.stats.QDStats.SType
-
This "magic" type gathers its grand-children's stats for any type of its child.
- ANY_BIND_ADDRESS - Static variable in interface com.devexperts.qd.qtp.MessageConnector.Bindable
-
Deprecated.
- ANYTHING - Static variable in class com.devexperts.qd.QDFilter
-
Filter that accepts everything.
- append(RecordCursor) - Method in class com.devexperts.qd.ng.AbstractRecordSink
-
- append(RecordCursor) - Method in class com.devexperts.qd.ng.RecordBuffer
-
Adds a record to this buffer from the specified
RecordCursor
.
- append(RecordCursor) - Method in interface com.devexperts.qd.ng.RecordSink
-
- append(RecordCursor) - Method in class com.devexperts.qd.qtp.AbstractQTPComposer
-
- append(RecordCursor) - Method in class com.devexperts.qd.qtp.OutputStreamComposer
-
- appendFromTextTokens(List<String>, int) - Method in class com.devexperts.qd.qtp.HeartbeatPayload
-
Adds information to this heartbeat payload from a list of strings that are parsed
from tab or comma separated text format.
- appendFromTextTokens(List<String>, int) - Method in class com.devexperts.qd.qtp.ProtocolDescriptor
-
Adds information to this protocol descriptor from a list of strings that are parsed
from tab or comma separated text format.
- appendTo(StringBuilder, int) - Static method in class com.devexperts.qd.util.Decimal
-
- applicationConnectionFactory(MessageAdapter.Factory) - Static method in class com.devexperts.qd.qtp.MessageConnectors
-
- applicationConnectionFactory(ConfigurableMessageAdapterFactory) - Static method in class com.devexperts.qd.qtp.MessageConnectors
-
- applyReadAs(ProtocolDescriptor) - Method in class com.devexperts.qd.qtp.AbstractQTPParser
-
- ArrayListAttachmentStrategy<T,C> - Class in com.devexperts.qd.kit
-
- ArrayListAttachmentStrategy() - Constructor for class com.devexperts.qd.kit.ArrayListAttachmentStrategy
-
- augmentProtocolDescriptor(ProtocolDescriptor) - Method in interface com.devexperts.qd.qtp.MasterMessageAdapter
-
- authenticate(AuthToken, TypedMap) - Method in interface com.devexperts.qd.qtp.auth.QDAuthRealm
-
Starts or restarts authentication procedure by this QDAuthRealm.
- AUTHENTICATION_LOGIN_REQUIRED - Static variable in class com.devexperts.qd.qtp.MessageAdapter
-
- AUTHENTICATION_PROPERTY - Static variable in class com.devexperts.qd.qtp.ProtocolDescriptor
-
- AUTHORIZATION_PROPERTY - Static variable in class com.devexperts.qd.qtp.ProtocolDescriptor
-
- average(int, int) - Static method in class com.devexperts.qd.util.Decimal
-
Averages two specified decimals and returns result as decimal.
- awaitProcessed() - Method in interface com.devexperts.qd.qtp.MessageConnector
-
Waits until this connector stops processing (becomes quescient).
- awaitProcessed() - Method in class com.devexperts.qd.qtp.QDEndpoint
-
- calculateDigest(DataScheme) - Static method in class com.devexperts.qd.kit.DefaultScheme
-
- cancel() - Method in interface com.devexperts.qd.util.DxTimer.Cancellable
-
- cancelScheduledTask() - Method in class com.devexperts.qd.qtp.AbstractServerConnector
-
- canReceive(MessageType) - Method in class com.devexperts.qd.qtp.ProtocolDescriptor
-
- canSend(MessageType) - Method in class com.devexperts.qd.qtp.ProtocolDescriptor
-
- CHANNEL_CONFIGURATION_KEY - Static variable in class com.devexperts.qd.qtp.auth.BasicChannelShaperFactory
-
- ChannelDescription - Class in com.devexperts.qd.qtp
-
Description of a single channel.
- ChannelDescription(String) - Constructor for class com.devexperts.qd.qtp.ChannelDescription
-
- ChannelShaper - Class in com.devexperts.qd.qtp
-
This class represents configuration of a single data channel within
AgentAdapter
.
- ChannelShaper(QDContract, Executor) - Constructor for class com.devexperts.qd.qtp.ChannelShaper
-
Creates new channel shaper with specified contract and subscription executor.
- ChannelShaper(QDContract, Executor, boolean) - Constructor for class com.devexperts.qd.qtp.ChannelShaper
-
Creates new channel shaper with specified contract, subscription executor,
and keep rejected flag.
- ChannelShaper(Executor, QDCollector, SubscriptionFilter, RecordFilter) - Constructor for class com.devexperts.qd.qtp.ChannelShaper
-
- ChannelShapersFactory - Interface in com.devexperts.qd.qtp.auth
-
The
ChannelShapersFactory
created of actual
ChannelShapers
based on
the
session
, which is provided by the corresponding
QDAuthRealm
.
- checkShortName(String) - Static method in class com.devexperts.qd.QDFilter
-
Checks validity of the short-name for the filter.
- CHUNK_POOL - Static variable in class com.devexperts.qd.qtp.FileConstants
-
- CHUNK_SIZE - Static variable in class com.devexperts.qd.qtp.FileConstants
-
Chunk size for files.
- cipher - Variable in class com.devexperts.qd.SymbolCodec.Reader
-
- ciphers - Variable in class com.devexperts.qd.SymbolList
-
- cleanup(RecordCursor) - Method in class com.devexperts.qd.ng.RecordBuffer
-
- cleanupConnectors() - Method in class com.devexperts.qd.qtp.QDEndpoint
-
Permanently closes all connectors and cleans up their resources.
- cleanupConnectorsImpl(Collection<MessageConnector>) - Method in class com.devexperts.qd.qtp.QDEndpoint
-
- clear() - Method in class com.devexperts.qd.DataBuffer
-
Deprecated.
Clears this data buffer.
- clear(int) - Method in enum com.devexperts.qd.ng.EventFlag
-
- clear() - Method in class com.devexperts.qd.ng.RecordBuffer
-
Clears this record buffers completely, invalidating read and write cursors, resetting its
size
,
position
and
limit
to zero.
- clear() - Method in class com.devexperts.qd.qtp.HeartbeatPayload
-
- clear() - Method in class com.devexperts.qd.SubscriptionBuffer
-
Deprecated.
Clears this subscription buffer.
- clear() - Method in class com.devexperts.qd.util.ByteArrayBuffer
-
Deprecated.
Clears this buffer.
- clear() - Method in class com.devexperts.qd.util.SymbolObjectMap
-
- clear() - Method in class com.devexperts.qd.util.SymbolSet
-
- clearData() - Method in class com.devexperts.qd.ng.RecordCursor
-
- clearDataButTime() - Method in class com.devexperts.qd.ng.RecordCursor
-
Clears all data fields but time (ints set to 0 and objs set to null).
- clearDataInBuffer(RecordBuffer, boolean) - Static method in class com.devexperts.qd.qtp.AgentChannels
-
- clearFields() - Method in class com.devexperts.qd.ng.RecordCursor
-
- clearMessageMask(long, MessageType) - Static method in class com.devexperts.qd.qtp.MessageAdapter
-
- CLIENT_SOCKET_CONNECTOR - Static variable in class com.devexperts.qd.stats.QDStats.SType
-
- ClientSocketConnector - Class in com.devexperts.qd.qtp.socket
-
The ClientSocketConnector
handles standard client socket using blocking API.
- ClientSocketConnector(MessageAdapter.Factory, String, int) - Constructor for class com.devexperts.qd.qtp.socket.ClientSocketConnector
-
- ClientSocketConnector(ApplicationConnectionFactory, String, int) - Constructor for class com.devexperts.qd.qtp.socket.ClientSocketConnector
-
Deprecated.
- ClientSocketConnector(ApplicationConnectionFactory, String) - Constructor for class com.devexperts.qd.qtp.socket.ClientSocketConnector
-
Creates new client socket connector.
- ClientSocketConnectorMBean - Interface in com.devexperts.qd.qtp.socket
-
- clone() - Method in class com.devexperts.qd.qtp.ChannelShaper
-
- clone() - Method in class com.devexperts.qd.qtp.DynamicChannelShaper
-
- clone() - Method in class com.devexperts.qd.qtp.MessageAdapter.ConfigurableFactory
-
Creates a copy of this factory with the same configuration.
- clone() - Method in class com.devexperts.qd.qtp.MessageAdapterConnectionFactory
-
- clone() - Method in class com.devexperts.qd.qtp.QDEndpoint.Builder
-
- close() - Method in interface com.devexperts.qd.QDAgent
-
Closes this agent and releases allocated resources in its
QDCollector
.
- close() - Method in interface com.devexperts.qd.QDCollector
-
Closes this collector and frees all external resources that are associated with it.
- close() - Method in interface com.devexperts.qd.QDDistributor
-
Closes this distributor and releases allocated resources in its
QDCollector
.
- close() - Method in class com.devexperts.qd.qtp.AbstractMessageConnector
-
- close() - Method in class com.devexperts.qd.qtp.AgentChannels
-
- close() - Method in class com.devexperts.qd.qtp.ChannelShaper
-
Closes this channel shaper and releases its resources (stops tracking dynamic filters).
- close() - Method in class com.devexperts.qd.qtp.DynamicChannelShaper
-
- close() - Method in class com.devexperts.qd.qtp.MessageAdapter
-
Closes this adapter.
- close() - Method in interface com.devexperts.qd.qtp.MessageAdapterMBean
-
- close() - Method in interface com.devexperts.qd.qtp.MessageConnector
-
Permanently closes connector and releases its resources.
- close() - Method in class com.devexperts.qd.qtp.OutputStreamMessageVisitor
-
- close() - Method in class com.devexperts.qd.qtp.QDEndpoint
-
Closes this endpoint.
- close() - Method in class com.devexperts.qd.qtp.QTPWorkerThread
-
Marks thread as "closed" and interrupts it (if needed).
- close() - Method in class com.devexperts.qd.stats.QDStats
-
- closeAndExamineDataBySubscription(RecordSink) - Method in interface com.devexperts.qd.QDAgent
-
Closes this agent and with
QDAgent.close()
and atomically examines all data that is
available for this agent in the collector storage.
- closeAndExamineDataBySubscription(RecordBuffer) - Method in class com.devexperts.qd.qtp.AgentChannels
-
- closeChildren() - Method in class com.devexperts.qd.stats.QDStats
-
- closeConnections(double, String, boolean) - Method in class com.devexperts.qd.qtp.AbstractServerConnector
-
Smooth closing a percent of connections during a specified period.
- closeConnections(double, String, boolean) - Method in interface com.devexperts.qd.qtp.ServerConnectorMBean
-
Gracefully close the percentage of connections within period of time
- closeImpl(Throwable) - Method in class com.devexperts.qd.qtp.AbstractConnectionHandler
-
- closeImpl() - Method in class com.devexperts.qd.qtp.AbstractMessageConnector
-
- closeImpl() - Method in class com.devexperts.qd.qtp.AgentAdapter
-
- closeImpl() - Method in class com.devexperts.qd.qtp.DistributorAdapter
-
- closeImpl() - Method in class com.devexperts.qd.qtp.MessageAdapter
-
- closeImpl() - Method in class com.devexperts.qd.qtp.QDEndpoint
-
- closeImpl() - Method in class com.devexperts.qd.stats.QDStats
-
- closeInternal() - Method in class com.devexperts.qd.stats.QDStats
-
- closeListener - Variable in class com.devexperts.qd.qtp.MessageAdapter
-
- closeListener - Variable in class com.devexperts.qd.qtp.socket.ServerSocketConnector
-
- closePart(int) - Method in interface com.devexperts.qd.QDAgent
-
Closes
part of this agent and releases allocated resources in its
QDCollector
.
- closeStats() - Method in class com.devexperts.qd.stats.QDStats
-
- CODE_LENGTH - Static variable in class com.devexperts.qd.kit.RangeUtil
-
- codec - Variable in class com.devexperts.qd.kit.DefaultScheme
-
- codec - Variable in class com.devexperts.qd.kit.RangeStriper
-
- codeLength - Variable in class com.devexperts.qd.kit.RangeStriper
-
- collectorBuilder(QDContract) - Method in class com.devexperts.qd.QDFactory
-
Creates builder for an collector that has specified contract.
- collectors - Variable in class com.devexperts.qd.qtp.QDEndpoint.Builder
-
- com.devexperts.qd - package 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 - package 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 - package com.devexperts.qd.ng
-
This package contains next-generation interfaces for data and subscription exchange based on
RecordCursor
class.
- com.devexperts.qd.qtp - package com.devexperts.qd.qtp
-
This package contains interfaces with default implementations required
to create and operate a connection using QTP.
- com.devexperts.qd.qtp.auth - package com.devexperts.qd.qtp.auth
-
- com.devexperts.qd.qtp.fieldreplacer - package com.devexperts.qd.qtp.fieldreplacer
-
- com.devexperts.qd.qtp.help - package com.devexperts.qd.qtp.help
-
- com.devexperts.qd.qtp.socket - package com.devexperts.qd.qtp.socket
-
This package contains a QTP connectors which use standard Java sockets.
- com.devexperts.qd.spi - package com.devexperts.qd.spi
-
Project-specific extension points.
- com.devexperts.qd.stats - package com.devexperts.qd.stats
-
- com.devexperts.qd.util - package 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.
- combineFactories(List<QDFilterFactory>) - Static method in class com.devexperts.qd.spi.QDFilterFactory
-
- combineFactories(List<SymbolStriperFactory>) - Static method in class com.devexperts.qd.spi.SymbolStriperFactory
-
- compact() - Method in class com.devexperts.qd.ng.RecordBuffer
-
Compacts data by copying everything between position and limit to the beginning of the buffer.
- compact(RecordFilter) - Method in class com.devexperts.qd.ng.RecordBuffer
-
Compacts data by copying all records that are accepted by filter between position and limit to
the beginning of the buffer.
- COMPACT_INT - Static variable in class com.devexperts.qd.SerialFieldType
-
- CompactChar - Class in com.devexperts.qd.util
-
- CompactCharField - Class in com.devexperts.qd.kit
-
The CompactCharField
represents a single character field
with UTF-8 serialized form.
- CompactCharField(int, String) - Constructor for class com.devexperts.qd.kit.CompactCharField
-
- CompactCharField(int, String, SerialFieldType) - Constructor for class com.devexperts.qd.kit.CompactCharField
-
- CompactInt - Class in com.devexperts.qd.util
-
- CompactIntField - Class in com.devexperts.qd.kit
-
The CompactIntField
represents an integer field
with compact serialized form.
- CompactIntField(int, String) - Constructor for class com.devexperts.qd.kit.CompactIntField
-
- CompactIntField(int, String, SerialFieldType) - Constructor for class com.devexperts.qd.kit.CompactIntField
-
- compare(int, int) - Static method in class com.devexperts.qd.util.Decimal
-
Compares two specified decimals for order.
- compareByString(char[], String, int) - Static method in class com.devexperts.qd.kit.RangeUtil
-
Utility method to compare two strings: one as a char array and another one as a substring.
- compareTo(Object) - Method in class com.devexperts.qd.util.Decimal
-
- completeIteration() - Method in class com.devexperts.qd.DataBuffer
-
Deprecated.
Checks and completes ongoing iteration if it has finished current record.
- completePortPromise(String, int) - Static method in class com.devexperts.qd.qtp.socket.ServerSocketTestHelper
-
Deprecated.
Fill a port promise associated with provided connector name (if it exists).
- completeVisit() - Method in class com.devexperts.qd.DataBuffer
-
Deprecated.
Checks and completes ongoing visit if it has finished current record.
- compose(MessageProvider) - Method in class com.devexperts.qd.qtp.AbstractQTPComposer
-
Composes message from the corresponding message provider to
output
and updates number of written bytes in
stats
.
- compose(MessageProvider, QDStats) - Method in class com.devexperts.qd.qtp.ByteArrayComposer
-
Deprecated.
Composes message from the corresponding message provides and update IO bytes written in stats.
- compose(double) - Static method in class com.devexperts.qd.util.Decimal
-
Returns decimal value for the corresponding double
.
- composeCollector(QDCollector) - Method in class com.devexperts.qd.qtp.OutputStreamComposer
-
Composes specified collector.
- composeDecimal(long, int) - Static method in class com.devexperts.qd.util.Decimal
-
Returns decimal value that corresponds to mantissa / 10^precision
.
- composeDescribeProtocol(ProtocolDescriptor) - Method in class com.devexperts.qd.qtp.AbstractQTPComposer
-
Composes describe protocol message to
output
and updates number of written bytes in
stats
.
- composeEmptyHeartbeat() - Method in class com.devexperts.qd.qtp.AbstractQTPComposer
-
Composes empty heartbeat message to
output
and updates number of written bytes in
stats
.
- composeEndpoint(QDEndpoint) - Method in class com.devexperts.qd.qtp.OutputStreamComposer
-
Composes all collectors defined in specified endpoint.
- composeHeartbeatMessage(HeartbeatPayload) - Method in class com.devexperts.qd.qtp.AbstractQTPComposer
-
Composes heartbeat message to
output
and updates number of written bytes in
stats
.
- COMPOSER_BUFFER_SIZE - Static variable in class com.devexperts.qd.qtp.QTPConstants
-
Defines default size of the composer buffer that is kept in each composer instance.
- COMPOSER_THRESHOLD - Static variable in class com.devexperts.qd.qtp.QTPConstants
-
Defines default threshold for the size of the composed packet.
- composeTimeProgressReport(long) - Method in class com.devexperts.qd.qtp.AbstractQTPComposer
-
Composes heartbeat message with progress report to
output
and updates number of written bytes in
stats
.
- composeTo(BufferedOutput) - Method in class com.devexperts.qd.qtp.HeartbeatPayload
-
Composes this heartbeat payload in compact binary format.
- composeTo(BufferedOutput) - Method in class com.devexperts.qd.qtp.ProtocolDescriptor
-
- CompositeFilters - Class in com.devexperts.qd.kit
-
SubscriptionFilter
utilities that combine other filters with ',' (or) operations,
'&' (and) operations, and '!' (not) operations.
- CompositeRecordProvider - Class in com.devexperts.qd.util
-
This class provides an efficient implementation of composite
RecordProvider
that listens for multiple
RecordProvider
instances and on
retrieve
method invocation only retrieves
data from the providers that have data available.
- CompositeRecordProvider(RecordProvider...) - Constructor for class com.devexperts.qd.util.CompositeRecordProvider
-
Constructs an instance of CompositeRecordProvider
for a given list of individual providers.
- CONFIG_SUFFIX - Static variable in class com.devexperts.qd.qtp.auth.BasicAuthRealmFactory
-
- configurable(MessageAdapter.Factory) - Static method in class com.devexperts.qd.qtp.MessageConnectors
-
- ConfigurableFactory() - Constructor for class com.devexperts.qd.qtp.MessageAdapter.ConfigurableFactory
-
- configurableFactory(MessageAdapter.Factory) - Static method in class com.devexperts.qd.qtp.MessageConnectors
-
- ConfigurableMessageAdapterFactory - Interface in com.devexperts.qd.qtp
-
- connect(String) - Method in class com.devexperts.qd.qtp.QDEndpoint
-
Connects the endpoint to specified address(es).
- CONNECTION - Static variable in class com.devexperts.qd.stats.QDStats.SType
-
- CONNECTION_RESTORE_TIME - Static variable in class com.devexperts.qd.qtp.QTPConstants
-
Defines the connection recovery time for all client socket connections.
- connectionRestoreTime - Variable in class com.devexperts.qd.qtp.socket.ClientSocketConnector
-
- CONNECTIONS - Static variable in class com.devexperts.qd.stats.QDStats.SType
-
- connectionStats - Variable in class com.devexperts.qd.qtp.AbstractConnectionHandler
-
- connector - Variable in class com.devexperts.qd.qtp.AbstractConnectionHandler
-
- connectOrder - Variable in class com.devexperts.qd.qtp.socket.ClientSocketConnector
-
- ConnectOrder - Class in com.devexperts.qd.qtp.socket
-
ConnectOrder specifies a strategy of considering specified addresses in
ClientSocketConnector
during
connect/reconnect.
- connectorsChanged(List<MessageConnector>) - Method in class com.devexperts.qd.qtp.QDEndpoint.Plugin
-
- ConsoleLoginHandlerFactory - Class in com.devexperts.qd.qtp.auth
-
- ConsoleLoginHandlerFactory() - Constructor for class com.devexperts.qd.qtp.auth.ConsoleLoginHandlerFactory
-
- contains(Object) - Method in class com.devexperts.qd.qtp.ProtocolOption.Set
-
- contains(int, String) - Method in class com.devexperts.qd.util.SymbolObjectMap
-
- contains(int, char[], int, int) - Method in class com.devexperts.qd.util.SymbolObjectMap
-
- contains(int, String) - Method in class com.devexperts.qd.util.SymbolSet
-
- contains(int, char[], int, int) - Method in class com.devexperts.qd.util.SymbolSet
-
- contains(int, String) - Method in class com.devexperts.qd.util.SymbolSet.ListSet
-
- contains(int, char[], int, int) - Method in class com.devexperts.qd.util.SymbolSet.ListSet
-
- containsAll(SymbolSet) - Method in class com.devexperts.qd.util.SymbolSet
-
- convertToTextTokens() - Method in class com.devexperts.qd.qtp.HeartbeatPayload
-
Converts heartbeat payload to a list of strings for representation in tab or comma separated text format.
- convertToTextTokens() - Method in class com.devexperts.qd.qtp.ProtocolDescriptor
-
Converts this protocol descriptor to a list of strings for representation in tab or comma separated text format.
- copy(Object, Object, int, int, int) - Static method in class com.devexperts.qd.DataBuffer
-
Deprecated.
Copies cyclic array buffer from source to destination.
- copy(Object, Object, int, int, int) - Static method in class com.devexperts.qd.SubscriptionBuffer
-
Deprecated.
Copies cyclic array buffer from source to destination.
- copy(int, int, int) - Method in class com.devexperts.qd.util.ByteArrayBuffer
-
Deprecated.
Copies a region of bytes in the buffer.
- copyDataFrom(RecordCursor) - Method in class com.devexperts.qd.ng.RecordCursor
-
- copyFrom(DataIterator) - Method in class com.devexperts.qd.ng.RecordCursor
-
Copies data from the specified iterator into this cursor overwriting everything unconditionally.
- copyFrom(RecordCursor) - Method in class com.devexperts.qd.ng.RecordCursor
-
Copies data and extra values from the specified cursor into this cursor overwriting everything unconditionally.
- copyFrom(QDCollector.Builder<?>) - Method in interface com.devexperts.qd.QDCollector.Builder
-
Copies properties from others.
- copyOf(SymbolSet) - Static method in class com.devexperts.qd.util.SymbolSet
-
- CorruptedException() - Constructor for exception com.devexperts.qd.qtp.BinaryQTPParser.CorruptedException
-
- CorruptedException(Throwable) - Constructor for exception com.devexperts.qd.qtp.BinaryQTPParser.CorruptedException
-
- CorruptedMessageException(Throwable, int) - Constructor for exception com.devexperts.qd.qtp.BinaryQTPParser.CorruptedMessageException
-
- create(QDStats.SType) - Method in class com.devexperts.qd.stats.QDStats
-
Creates and returns new child with the corresponding type.
- create(QDStats.SType, String) - Method in class com.devexperts.qd.stats.QDStats
-
Creates and returns new child with the corresponding type and key properties.
- create(QDStats.SType, String, boolean) - Method in class com.devexperts.qd.stats.QDStats
-
Creates and returns new child with the corresponding type, key properties,
and an optional per-record tracking of stats.
- createAdapter(QDStats) - Method in class com.devexperts.qd.qtp.AgentAdapter.Factory
-
- createAdapter(QDStats) - Method in class com.devexperts.qd.qtp.DistributorAdapter.Factory
-
- createAdapter(QDStats) - Method in class com.devexperts.qd.qtp.MessageAdapter.ConfigurableFactory
-
Creates message adapter.
- createAdapter(QDStats) - Method in interface com.devexperts.qd.qtp.MessageAdapter.Factory
-
Creates message adapter.
- createAdapterWithSocket(Socket, QDStats) - Method in interface com.devexperts.qd.qtp.socket.SocketMessageAdapterFactory
-
Runs custom authorization/authentication protocol over given
socket
and
returns
MessageAdapter
for communication with remote host.
- createAgent(SubscriptionFilter) - Method in interface com.devexperts.qd.QDCollector
-
- createAgent(SubscriptionFilter, String) - Method in interface com.devexperts.qd.QDCollector
-
- createAgent(QDCollector, SubscriptionFilter, String) - Method in class com.devexperts.qd.qtp.AgentAdapter
-
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.
- createAgent(QDCollector, QDFilter) - Method in interface com.devexperts.qd.qtp.AgentChannels.Owner
-
This method is used internally by agent adapter to create agent for the corresponding
collector, filter when the corresponding subscription arrives for a first time.
- createAgentBuilder(QDCollector, SubscriptionFilter, String) - Method in class com.devexperts.qd.qtp.AgentAdapter
-
- createAndAddConnector(QDEndpoint, String) - Method in interface com.devexperts.qd.qtp.QDEndpoint.ConnectorInitializer
-
- createAuthRealm(String, MessageAdapterConnectionFactory) - Method in class com.devexperts.qd.qtp.auth.BasicAuthRealmFactory
-
Created BasicAuthRealm
.
- createAuthRealm(String, MessageAdapterConnectionFactory) - Method in interface com.devexperts.qd.qtp.auth.QDAuthRealmFactory
-
- createChannelShapers(AgentAdapter, AuthSession) - Method in class com.devexperts.qd.qtp.auth.BasicChannelShaperFactory
-
- createChannelShapers(AgentAdapter, AuthSession) - Method in interface com.devexperts.qd.qtp.auth.ChannelShapersFactory
-
Creates array of channel shapers.
- createCollector(QDFactory, QDCollector.Builder<?>) - Method in interface com.devexperts.qd.QDCollector.Factory
-
Creates collector instance using a given base factory, data scheme, and stats.
- createCollector(QDFactory, QDCollector.Builder<?>) - Method in enum com.devexperts.qd.QDContract
-
- createComposite(List<Consumer<RecordCursor>>) - Static method in class com.devexperts.qd.qtp.fieldreplacer.FieldReplacersCache
-
- createConnection(TransportConnection) - Method in class com.devexperts.qd.qtp.MessageAdapterConnectionFactory
-
- createDataScheme(String) - Method in interface com.devexperts.qd.DataSchemeFactory
-
Creates
data scheme
instance for the given specification.
- createDefaultIntInstance(int, String) - Method in class com.devexperts.qd.SerialFieldType
-
- createDefaultObjInstance(int, String) - Method in class com.devexperts.qd.SerialFieldType
-
- createDefaultScheme(ClassLoader) - Static method in class com.devexperts.qd.QDFactory
-
Creates default data scheme for a specified class loader.
- createDistributor(SubscriptionFilter) - Method in interface com.devexperts.qd.QDCollector
-
- createDistributor(SubscriptionFilter, String) - Method in interface com.devexperts.qd.QDCollector
-
- createDistributor(QDCollector, SubscriptionFilter, String) - Method in class com.devexperts.qd.qtp.DistributorAdapter
-
Deprecated.
- createDistributor(QDCollector, QDFilter, QDFilter, String) - Method in class com.devexperts.qd.qtp.DistributorAdapter
-
This method is used internally by distributor adapter to create agent for the corresponding
collector, filter, stripe, and keyProperties from this adapter's constructor.
- createFieldReplacer(DataRecord) - Method in interface com.devexperts.qd.qtp.FieldReplacer
-
- createFieldReplacer(String, DataScheme) - Method in class com.devexperts.qd.qtp.fieldreplacer.DateFieldReplacerFactory
-
- createFieldReplacer(DataRecord) - Method in class com.devexperts.qd.qtp.fieldreplacer.DefaultFieldReplacer
-
- createFieldReplacer(String, DataScheme) - Method in interface com.devexperts.qd.qtp.FieldReplacer.Factory
-
- createFieldReplacer(String, DataScheme) - Method in class com.devexperts.qd.qtp.fieldreplacer.SetFieldReplacerFactory
-
- createFieldReplacer(String, DataScheme) - Method in class com.devexperts.qd.qtp.fieldreplacer.TimeFieldReplacerFactory
-
- createFieldReplacer(String, DataScheme) - Method in class com.devexperts.qd.qtp.fieldreplacer.ValueFieldReplacerFactory
-
- createFilter(String) - Method in class com.devexperts.qd.spi.QDFilterFactory
-
Creates custom project-specific filter based on the specification string.
- createFilter(String, QDFilterContext) - Method in class com.devexperts.qd.spi.QDFilterFactory
-
Creates custom project-specific filter based on the specification string in the specified context.
- createFilter(String, SubscriptionFilter) - Method in class com.devexperts.qd.spi.QDFilterFactory
-
- createFilter(String, SubscriptionFilter) - Method in interface com.devexperts.qd.SubscriptionFilterFactory
-
Deprecated.
Creates SubscriptionFilter
based on the given spec
.
- createHandler(String, AbstractMessageConnector) - Method in interface com.devexperts.qd.qtp.AbstractConnectionHandler.Factory
-
- createHistory(DataScheme) - Method in class com.devexperts.qd.QDFactory
-
- createHistory(DataScheme, QDStats) - Method in class com.devexperts.qd.QDFactory
-
- createHistory(DataScheme, QDStats, HistorySubscriptionFilter) - Method in class com.devexperts.qd.QDFactory
-
- createInstance() - Static method in class com.devexperts.qd.util.SymbolObjectMap
-
- createInstance() - Static method in class com.devexperts.qd.util.SymbolSet
-
- createInternal(QDStats.SType, String, boolean, int, DataScheme) - Method in class com.devexperts.qd.stats.QDStats
-
- createLoginHandler(String, MessageAdapterConnectionFactory) - Method in class com.devexperts.qd.qtp.auth.BasicLoginHandlerFactory
-
- createLoginHandler(String, MessageAdapterConnectionFactory) - Method in class com.devexperts.qd.qtp.auth.ConsoleLoginHandlerFactory
-
- createLoginHandler(String, MessageAdapterConnectionFactory) - Method in interface com.devexperts.qd.qtp.auth.QDLoginHandlerFactory
-
Creates login handler.
- createMapping(DataRecord) - Method in interface com.devexperts.qd.ng.RecordMappingFactory
-
Creates mapping for a specified record.
- createMessageAdapterFactory(String) - Method in interface com.devexperts.qd.qtp.ConfigurableMessageAdapterFactory
-
Deprecated.
- createMessageAdapterFactory(String) - Method in class com.devexperts.qd.qtp.MessageAdapter.ConfigurableFactory
-
- createMessageConnector(ApplicationConnectionFactory, String) - Method in interface com.devexperts.qd.qtp.MessageConnectorFactory
-
Creates message connector with a given address.
- createMessageConnectors(ConfigurableMessageAdapterFactory, String, QDStats) - Static method in class com.devexperts.qd.qtp.MessageConnectors
-
Creates new connectors for specified addresses using specified
configurable adapter factory.
- createMessageConnectors(ApplicationConnectionFactory, String, QDStats) - Static method in class com.devexperts.qd.qtp.MessageConnectors
-
- createMessageConnectors(ApplicationConnectionFactory, String) - Static method in class com.devexperts.qd.qtp.MessageConnectors
-
- createNamedVoid(String) - Static method in class com.devexperts.qd.stats.QDStats
-
Returns an instance of
QDStats
that does not actually track anything
(is always empty like
QDStats.VOID
but is named).
- createPortPromise(String) - Static method in class com.devexperts.qd.qtp.socket.ServerSocketTestHelper
-
Deprecated.
Create a promise to retrieve a local port of specified server connector.
- createReader() - Method in class com.devexperts.qd.kit.PentaCodec
-
- createReader() - Method in interface com.devexperts.qd.SymbolCodec
-
Creates stateful symbol reader.
- createSocket(String, int) - Method in class com.devexperts.qd.qtp.socket.ClientSocketConnector
-
- createStats(QDStats.SType, DataScheme) - Static method in class com.devexperts.qd.QDFactory
-
Creates default implementation of
QDStats
with the specified type
and scheme.
- createStream(DataScheme) - Method in class com.devexperts.qd.QDFactory
-
- createStream(DataScheme, QDStats) - Method in class com.devexperts.qd.QDFactory
-
- createStriper(String) - Method in class com.devexperts.qd.kit.SymbolStriperFactoryImpl
-
- createStriper(String) - Method in class com.devexperts.qd.spi.SymbolStriperFactory
-
Creates custom project-specific filter based on the specification string.
- createTicker(DataScheme) - Method in class com.devexperts.qd.QDFactory
-
- createTicker(DataScheme, QDStats) - Method in class com.devexperts.qd.QDFactory
-
- createVoidAgent(QDContract) - Method in interface com.devexperts.qd.qtp.AgentChannels.Owner
-
This method is used to create void agent just to keep subscription.
- createVoidAgentBuilder(QDContract, DataScheme) - Method in class com.devexperts.qd.QDFactory
-
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.
- createWriter() - Method in class com.devexperts.qd.kit.PentaCodec
-
- createWriter() - Method in interface com.devexperts.qd.SymbolCodec
-
Creates stateful symbol writer.
- current() - Method in class com.devexperts.qd.ng.RecordBuffer
-
Returns read cursor at the current position.
- current() - Method in class com.devexperts.qd.ng.RecordSource
-
Returns read cursor at the current position.
- currentMessageType - Variable in class com.devexperts.qd.qtp.AbstractQTPComposer
-
- currentTimeMark() - Static method in class com.devexperts.qd.util.TimeMarkUtil
-
- cursor() - Method in class com.devexperts.qd.ng.RecordCursor.Owner
-
- cursorAt(long) - Method in class com.devexperts.qd.ng.RecordBuffer
-
Returns read cursor at a specified position.
- cursorAt(long) - Method in class com.devexperts.qd.ng.RecordSource
-
Returns read cursor at a specified position.
- CUSTOM_OBJECT - Static variable in class com.devexperts.qd.SerialFieldType
-
- empty - Variable in class com.devexperts.qd.qtp.BinaryRecordDesc
-
- EMPTY_CHILDREN - Static variable in class com.devexperts.qd.stats.QDStats
-
- EMPTY_SET - Static variable in enum com.devexperts.qd.qtp.ProtocolOption
-
Empty set of protocol options.
- encode(String) - Method in class com.devexperts.qd.kit.PentaCodec
-
- encode(char[], int, int) - Method in class com.devexperts.qd.kit.PentaCodec
-
- encode(String) - Method in interface com.devexperts.qd.SymbolCodec
-
Returns encoded cipher for specified symbol.
- encode(char[], int, int) - Method in interface com.devexperts.qd.SymbolCodec
-
Returns encoded cipher for specified symbol represented in
a character array.
- encode(String) - Static method in class com.devexperts.qd.util.ShortString
-
Encodes string up to 8 characters as a long.
- encode(String, int, int) - Static method in class com.devexperts.qd.util.ShortString
-
Encodes a portion of a string up to 8 character to a long.
- encode(char[], int, int) - Static method in class com.devexperts.qd.util.ShortString
-
Encodes a portion of a char array up to 8 character to a long.
- encode(byte[], int, int) - Static method in class com.devexperts.qd.util.ShortString
-
Encodes a portion of a byte array up to 8 character to a long.
- encodeInt(int) - Static method in class com.devexperts.qd.util.ShortString
-
Encodes integer number as a short string - up to 8 characters represented as a long.
- encodeSymbol(String) - Static method in class com.devexperts.qd.kit.RangeUtil
-
Encode the given symbol into the primitive long value.
- encodeSymbol(String, int, int) - Static method in class com.devexperts.qd.kit.RangeUtil
-
Encode the given symbol into the primitive long value.
- encodeSymbol(char[], int, int) - Static method in class com.devexperts.qd.kit.RangeUtil
-
- endMessage() - Method in class com.devexperts.qd.qtp.AbstractQTPComposer
-
- EndOfBufferException() - Constructor for exception com.devexperts.qd.util.ByteArrayDataInput.EndOfBufferException
-
Deprecated.
- endpoint - Variable in class com.devexperts.qd.qtp.MessageAdapter.AbstractFactory
-
- ensureCapacity(DataRecord) - Method in class com.devexperts.qd.DataBuffer
-
Deprecated.
Ensures that this buffer has capacity to visit and store specified record.
- ensureCapacity(int) - Method in class com.devexperts.qd.qtp.ByteArrayParser
-
Deprecated.
Ensures that byte array buffer has at least specified capacity.
- ensureCapacity(DataRecord) - Method in class com.devexperts.qd.SubscriptionBuffer
-
Deprecated.
Ensures that this buffer has capacity to visit and store specified record.
- ensureCapacity(int) - Method in class com.devexperts.qd.util.ByteArrayBuffer
-
Deprecated.
Ensures that the byte array has at least the specified capacity.
- eqType - Variable in class com.devexperts.qd.stats.QDStats.SType
-
- equals(int, int) - Method in interface com.devexperts.qd.DataIntField
-
Compares two specified field values for equality.
- equals(Object, Object) - Method in interface com.devexperts.qd.DataObjField
-
Compares two specified field values for equality.
- equals(int, int) - Method in class com.devexperts.qd.kit.AbstractDataIntField
-
Compares two specified field values for equality.
- equals(Object, Object) - Method in class com.devexperts.qd.kit.AbstractDataObjField
-
Compares two specified field values for equality.
- equals(Object, Object) - Method in class com.devexperts.qd.kit.ByteArrayField
-
- equals(Object) - Method in class com.devexperts.qd.kit.NotFilter
-
- equals(Object) - Method in class com.devexperts.qd.kit.PatternFilter
-
- equals(Object, Object) - Method in class com.devexperts.qd.kit.StringField
-
- equals(Object) - Method in class com.devexperts.qd.kit.SymbolSetFilter
-
- equals(Object) - Method in class com.devexperts.qd.qtp.MessageDescriptor
-
- equals(Object) - Method in class com.devexperts.qd.qtp.socket.ConnectOrder
-
- equals(Object) - Method in class com.devexperts.qd.qtp.socket.SocketAddress
-
- equals(Object) - Method in class com.devexperts.qd.SerialFieldType
-
- equals(Object) - Method in class com.devexperts.qd.util.Decimal
-
- equals(String, char[], int, int, int) - Static method in class com.devexperts.qd.util.StringUtil
-
- equals(String, char[], int, int) - Static method in class com.devexperts.qd.util.StringUtil
-
- equals(Object) - Method in class com.devexperts.qd.util.SymbolSet
-
- escape(String) - Static method in class com.devexperts.qd.util.QDConfig
-
Adds backslash escaped to all characters in the string that are consider special in QD configuration
strings: '(', ')', '[', ']', ',', '+', '@', '\'.
- ESCAPE_CHAR - Static variable in class com.devexperts.qd.util.QDConfig
-
Backslash.
- EVENT_FIELDS_PREFIX - Static variable in class com.devexperts.qd.qtp.BuiltinFields
-
All built-in event fields are prefixed with this string.
- EVENT_FLAGS_FIELD_NAME - Static variable in class com.devexperts.qd.qtp.BuiltinFields
-
This pseudo field name is reserved to represent event flags and cannot
be used as any kind of field name.
- EVENT_SEQUENCE_FIELD_NAME - Static variable in class com.devexperts.qd.qtp.BuiltinFields
-
The name of virtual field that stores EventSequence.
- EVENT_SYMBOL_FIELD_NAME - Static variable in class com.devexperts.qd.qtp.BuiltinFields
-
This pseudo field name is reserved to represent the symbol and cannot
be used as any kind of field name.
- EVENT_TIME_FIELD_NAME - Static variable in class com.devexperts.qd.qtp.BuiltinFields
-
The name of virtual field that stores EventTime.
- EventFlag - Enum in com.devexperts.qd.ng
-
Event flags.
- eventFlags - Variable in class com.devexperts.qd.SymbolCodec.Reader
-
- eventFlagsBytes - Variable in class com.devexperts.qd.SymbolCodec.Reader
-
- eventTimeSequence - Variable in class com.devexperts.qd.qtp.AbstractQTPParser
-
Time and sequence which should be set to cursor.
- examine(SymbolReceiver) - Method in class com.devexperts.qd.util.SymbolSet
-
Examines set via specified SymbolReceiver
.
- examine(SymbolReceiver) - Method in class com.devexperts.qd.util.SymbolSet.ListSet
-
- examineData(DataVisitor) - Method in class com.devexperts.qd.DataBuffer
-
Deprecated.
Examines accumulated data via specified data visitor.
- examineData(DataVisitor) - Method in class com.devexperts.qd.ng.RecordCursor
-
Examines this cursor into the specified data visitor,
passing record, symbol and all field values.
- examineData(DataVisitor) - Method in interface com.devexperts.qd.QDCollector
-
- examineData(RecordSink) - Method in interface com.devexperts.qd.QDCollector
-
Examines all stored data via specified record sink.
- examineData(DataRecord, int, String, long, long, DataVisitor) - Method in interface com.devexperts.qd.QDHistory
-
- examineData(DataRecord, int, String, long, long, RecordSink) - Method in interface com.devexperts.qd.QDHistory
-
Examines available records for specified parameters via specified data visitor.
- examineDataBySubscription(RecordSink, RecordSource) - Method in interface com.devexperts.qd.QDCollector
-
Examines all stored data for a given subscription via specified sink.
- examineEntries(SymbolObjectVisitor<T>) - Method in class com.devexperts.qd.util.SymbolObjectMap
-
Examines map entries via specified SymbolObjectVisitor
.
- examineRecord(int, DataVisitor) - Method in class com.devexperts.qd.DataBuffer
-
Deprecated.
Examines record by its index within this buffer via specivied visitor.
- examineRecord(int, SubscriptionVisitor) - Method in class com.devexperts.qd.SubscriptionBuffer
-
Deprecated.
Examines record by its index within this buffer via specivied visitor.
- examineSubscription(SubscriptionVisitor) - Method in class com.devexperts.qd.ng.RecordCursor
-
Examines this cursor into the specified data visitor,
passing record, symbol and time (if this cursor
has time
).
- examineSubscription(SubscriptionVisitor) - Method in class com.devexperts.qd.SubscriptionBuffer
-
Deprecated.
Examines accumulated subscription via specified subscription visitor.
- examineSubscription(SubscriptionVisitor) - Method in interface com.devexperts.qd.SubscriptionContainer
-
- examineSubscription(RecordSink) - Method in interface com.devexperts.qd.SubscriptionContainer
-
Examines subscription and passes it to the record sink.
- examiningIterator() - Method in class com.devexperts.qd.DataBuffer
-
Deprecated.
Returns data iterator that examines this data buffer.
- examiningIterator(boolean) - Method in class com.devexperts.qd.DataBuffer
-
Deprecated.
Returns data iterator that examines this data buffer with optional reversal.
- examiningIterator(int, int) - Method in class com.devexperts.qd.DataBuffer
-
Deprecated.
Returns data iterator that examines this data buffer in the given range.
- examiningIterator() - Method in class com.devexperts.qd.SubscriptionBuffer
-
Deprecated.
Returns subscription iterator that examines this subscription buffer.
- examiningProvider() - Method in class com.devexperts.qd.DataBuffer
-
Deprecated.
- executeLockBoundTask(Executor, Runnable) - Method in interface com.devexperts.qd.QDCollector
-
Cooperative mechanism to execute a task that spends most of its time under the global lock of this collector
(like add/remove/set subscription or closing of agent).
- expandLimit(int) - Method in class com.devexperts.qd.util.ByteArrayBuffer
-
Deprecated.
Expands byte array to the specified limit (or more).
- expandLimit(int) - Method in class com.devexperts.qd.util.ByteArrayDataInput
-
Deprecated.
- generateRandomSublist(int) - Method in class com.devexperts.qd.SymbolList
-
- get(QDStats.SType) - Method in class com.devexperts.qd.stats.QDStats
-
Returns the first found child with the specified type or null
if not found.
- get(QDStats.SType, String) - Method in class com.devexperts.qd.stats.QDStats
-
Returns the first found child with the corresponding type and key properties or null
if not found.
- get(int, String) - Method in class com.devexperts.qd.util.SymbolObjectMap
-
- get(int, char[], int, int) - Method in class com.devexperts.qd.util.SymbolObjectMap
-
- getAcceptedSocketAddress(Socket) - Static method in class com.devexperts.qd.qtp.socket.SocketUtil
-
- getAddedRecordProvider() - Method in interface com.devexperts.qd.QDDistributor
-
Returns record provider that is used to accumulate added subscription.
- getAddedSubscriptionProvider() - Method in interface com.devexperts.qd.QDDistributor
-
- getAddingSubscriptionConsumer() - Method in interface com.devexperts.qd.QDAgent
-
- getAddress() - Method in class com.devexperts.qd.qtp.AbstractServerConnector
-
- getAddress() - Method in interface com.devexperts.qd.qtp.MessageConnectorMBean
-
Address string of connector.
- getAddress() - Method in class com.devexperts.qd.qtp.socket.ClientSocketConnector
-
- getAggregationPeriod() - Method in class com.devexperts.qd.qtp.AgentAdapter.Factory
-
- getAggregationPeriod() - Method in class com.devexperts.qd.qtp.ChannelShaper
-
Returns aggregation period in milliseconds for this channel data.
- getAll(QDStats.SType) - Method in class com.devexperts.qd.stats.QDStats
-
Returns all children with the corresponding type.
- getAsDouble(RecordCursor, int) - Method in class com.devexperts.qd.ng.RecordMapping
-
- getAsInt(RecordCursor, int) - Method in class com.devexperts.qd.ng.RecordMapping
-
- getAsLong(RecordCursor, int) - Method in class com.devexperts.qd.ng.RecordMapping
-
- getAsTimeMillis(RecordCursor, int) - Method in class com.devexperts.qd.ng.RecordMapping
-
- getAsTimeSeconds(RecordCursor, int) - Method in class com.devexperts.qd.ng.RecordMapping
-
- getAsTinyDecimal(RecordCursor, int) - Method in class com.devexperts.qd.ng.RecordMapping
-
- getAsWideDecimal(RecordCursor, int) - Method in class com.devexperts.qd.ng.RecordMapping
-
- getAttachment() - Method in class com.devexperts.qd.ng.RecordCursor
-
Returns object attachment that is associated with the current record.
- getAttachmentStrategy() - Method in interface com.devexperts.qd.QDAgent.Builder
-
- getAuth() - Method in class com.devexperts.qd.qtp.MessageAdapterConnectionFactory
-
- getAuthenticationInfo() - Method in interface com.devexperts.qd.qtp.auth.QDAuthRealm
-
Returns introductory information for the client about the authentication procedure.
- getAuthToken() - Method in class com.devexperts.qd.qtp.auth.BasicLoginHandler
-
- getAuthToken() - Method in interface com.devexperts.qd.qtp.auth.QDLoginHandler
-
Returns current token or null
if not authenticated yet.
- getAvailableCount(DataRecord, int, String, long, long) - Method in interface com.devexperts.qd.QDHistory
-
Returns the number of available records for specified parameters.
- getBindAddr() - Method in class com.devexperts.qd.qtp.AbstractServerConnector
-
- getBindAddr() - Method in interface com.devexperts.qd.qtp.MessageConnector.Bindable
-
Deprecated.
- getBindAddr() - Method in interface com.devexperts.qd.qtp.ServerConnectorMBean
-
Network interface address to bind socket to
- getBindInetAddress() - Method in class com.devexperts.qd.qtp.AbstractServerConnector
-
- getBuffer() - Method in class com.devexperts.qd.qtp.ByteArrayComposer
-
Deprecated.
Returns byte array buffer where data is stored.
- getBuffer() - Method in class com.devexperts.qd.qtp.ByteArrayParser
-
Deprecated.
Returns byte array buffer where data is stored.
- getBuffer() - Method in class com.devexperts.qd.util.ByteArrayBuffer
-
Deprecated.
Returns the byte array that backs this buffer.
- getChannels() - Method in class com.devexperts.qd.qtp.AgentAdapter.Factory
-
- getChildren() - Method in class com.devexperts.qd.stats.QDStats
-
- getCipher(int) - Method in class com.devexperts.qd.DataBuffer
-
Deprecated.
Returns cipher of the record by its index within this buffer.
- getCipher() - Method in class com.devexperts.qd.DataBuffer
-
Deprecated.
- getCipher() - Method in interface com.devexperts.qd.DataIterator
-
- getCipher() - Method in class com.devexperts.qd.ng.RecordBuffer
-
- getCipher() - Method in class com.devexperts.qd.ng.RecordCursor
-
Returns cipher or 0 if symbol is not coded.
- getCipher() - Method in class com.devexperts.qd.ng.RecordSource
-
- getCipher(int) - Method in class com.devexperts.qd.SubscriptionBuffer
-
Deprecated.
Returns cipher of the record by its index within this buffer.
- getCipher() - Method in class com.devexperts.qd.SubscriptionBuffer
-
Deprecated.
- getCipher() - Method in interface com.devexperts.qd.SubscriptionIterator
-
- getCipher() - Method in class com.devexperts.qd.SymbolCodec.Reader
-
- getCipher(int) - Method in class com.devexperts.qd.SymbolList
-
- getCipherAt(long) - Method in class com.devexperts.qd.ng.RecordBuffer
-
Returns cipher at the specified position.
- getClosedConnectionCount() - Method in class com.devexperts.qd.qtp.AbstractMessageConnector
-
- getClosedConnectionCount() - Method in interface com.devexperts.qd.qtp.MessageConnector
-
Returns total number of closed connector since the creation of connector.
- getCodec() - Method in interface com.devexperts.qd.DataScheme
-
Returns symbol codec used in this scheme.
- getCodec() - Method in class com.devexperts.qd.kit.DefaultScheme
-
- getCodecFactory(ApplicationConnectionFactory, Class<T>) - Static method in class com.devexperts.qd.qtp.MessageConnectors
-
- getCollector() - Method in class com.devexperts.qd.qtp.ChannelShaper
-
Returns collector currently used by the channel.
- getCollector(QDContract) - Method in class com.devexperts.qd.qtp.DistributorAdapter
-
- getCollector(QDContract) - Method in class com.devexperts.qd.qtp.QDEndpoint
-
- getCollectors() - Method in class com.devexperts.qd.qtp.MessageAdapter.AbstractFactory
-
- getCollectors() - Method in class com.devexperts.qd.qtp.QDEndpoint
-
- getCommonScheme(QDCollector, QDCollector, QDCollector) - Static method in class com.devexperts.qd.qtp.MessageAdapter
-
Returns common data scheme or throws IllegalArgumentException.
- getConfiguration(ConfigurationKey<T>) - Method in class com.devexperts.qd.qtp.MessageAdapterConnectionFactory
-
- getConnectionCount() - Method in interface com.devexperts.qd.qtp.MessageConnectorMBean
-
Number of established connections
- getConnectionCount() - Method in class com.devexperts.qd.qtp.socket.ClientSocketConnector
-
- getConnectionCount() - Method in class com.devexperts.qd.qtp.socket.ServerSocketConnector
-
- getConnections() - Method in class com.devexperts.qd.qtp.AbstractServerConnector
-
- getConnections() - Method in class com.devexperts.qd.qtp.socket.ServerSocketConnector
-
- getConnectionStats() - Method in class com.devexperts.qd.qtp.AbstractConnectionHandler
-
- getConnectionVariables() - Method in class com.devexperts.qd.qtp.MessageAdapter
-
Returns per-connection variables for this message adapter.
- getConnectOrder() - Method in class com.devexperts.qd.qtp.socket.ClientSocketConnector
-
- getConnectOrder() - Method in interface com.devexperts.qd.qtp.socket.ClientSocketConnectorMBean
-
- getConnectors() - Method in class com.devexperts.qd.qtp.QDEndpoint
-
- getContract() - Method in interface com.devexperts.qd.QDCollector.Builder
-
Returns collector's contract.
- getContract() - Method in interface com.devexperts.qd.QDCollector.Factory
-
Returns this factory's contract.
- getContract() - Method in interface com.devexperts.qd.QDCollector
-
Returns contract that this collector provides.
- getContract() - Method in enum com.devexperts.qd.QDContract
-
- getContract() - Method in class com.devexperts.qd.qtp.ChannelShaper
-
Returns contract of the channel.
- getContract() - Method in enum com.devexperts.qd.qtp.MessageType
-
- getContracts() - Method in class com.devexperts.qd.qtp.QDEndpoint
-
- getCurrentAddresses() - Method in class com.devexperts.qd.qtp.socket.ClientSocketConnector
-
- getCurrentAddresses() - Method in interface com.devexperts.qd.qtp.socket.ClientSocketConnectorMBean
-
List of addresses (host:port) for all active connections
- getCurrentHost() - Method in class com.devexperts.qd.qtp.socket.ClientSocketConnector
-
- getCurrentHost() - Method in interface com.devexperts.qd.qtp.socket.ClientSocketConnectorMBean
-
Current IP address of connection when connecting to the cluster
- getCurrentPort() - Method in class com.devexperts.qd.qtp.socket.ClientSocketConnector
-
- getCurrentPort() - Method in interface com.devexperts.qd.qtp.socket.ClientSocketConnectorMBean
-
- getData(RecordCursor.Owner, DataRecord, int, String) - Method in interface com.devexperts.qd.QDTicker
-
Gets all data for the specified record, cipher, and symbol in a single call
and sets
RecordCursor
via caller-provided
RecordCursor.Owner
to the
corresponding memory storage in read-only mode.
- getDataFilter() - Method in class com.devexperts.qd.qtp.ChannelShaper
-
Returns data filter currently used by the channel.
- getDataIfAvailable(RecordCursor.Owner, DataRecord, int, String) - Method in interface com.devexperts.qd.QDTicker
-
Gets all data for the specified record, cipher, and symbol in a single call
and sets
RecordCursor
via caller-provided
RecordCursor.Owner
to the
corresponding memory storage in read-only mode if the corresponding data
is available in the storage.
- getDataIfSubscribed(RecordCursor.Owner, DataRecord, int, String) - Method in interface com.devexperts.qd.QDTicker
-
- getDecimalMantissa(int) - Static method in class com.devexperts.qd.util.Decimal
-
Returns decimal mantissa of the decimal number.
- getDecimalPrecision(int) - Static method in class com.devexperts.qd.util.Decimal
-
Returns decimal precision of the decimal number.
- getDecodedSymbol() - Method in class com.devexperts.qd.ng.RecordCursor
-
Returns symbol that is decoded from cipher if needed.
- getDefaultFactory() - Static method in class com.devexperts.qd.QDFactory
-
Returns default QD factory.
- getDefaultName() - Method in class com.devexperts.qd.kit.NotFilter
-
- getDefaultName() - Method in class com.devexperts.qd.kit.PatternFilter
-
- getDefaultName() - Method in class com.devexperts.qd.kit.SymbolSetFilter
-
- getDefaultName() - Method in class com.devexperts.qd.QDFilter
-
Composes default string representation of the filter.
- getDefaultPropertyName(String) - Static method in class com.devexperts.qd.kit.AbstractDataField
-
- getDefaultScheme() - Static method in class com.devexperts.qd.QDFactory
-
Returns default data scheme for a system class loader.
- getDeltaMark() - Method in class com.devexperts.qd.qtp.HeartbeatPayload
-
- getDescriptorProperties() - Method in class com.devexperts.qd.qtp.QDEndpoint
-
- getDigest() - Method in interface com.devexperts.qd.DataScheme
-
Returns digest of the scheme.
- getDigest() - Method in class com.devexperts.qd.kit.DefaultScheme
-
- getEnableWildcards() - Method in interface com.devexperts.qd.QDStream
-
Returns status of "wildcards enabled" mode.
- getEndpoint(Class<T>) - Method in class com.devexperts.qd.qtp.MessageAdapter.ConfigurableFactory
-
- getEndpoint() - Method in class com.devexperts.qd.qtp.MessageAdapter
-
Returns endpoint of this message adapter.
- getEndpoint(Class<T>) - Method in class com.devexperts.qd.qtp.MessageAdapterConnectionFactory
-
- getEndpointId() - Method in class com.devexperts.qd.qtp.ProtocolDescriptor
-
- getEndpointId() - Method in class com.devexperts.qd.qtp.QDEndpoint
-
- getEndpointStats() - Method in class com.devexperts.qd.qtp.AbstractMessageConnector
-
- getEndpointStats() - Method in interface com.devexperts.qd.qtp.MessageConnectorMBean
-
Endpoint statistics since last reset
- getEndpointStats(Collection<? extends MessageConnector>) - Static method in class com.devexperts.qd.qtp.MessageConnectors
-
- getEventFlags() - Method in class com.devexperts.qd.ng.RecordCursor
-
Returns event flags that are associated with the current record.
- getEventFlags() - Method in class com.devexperts.qd.SymbolCodec.Reader
-
- getEventFlagsBytes() - Method in class com.devexperts.qd.SymbolCodec.Reader
-
- getEventSequence() - Method in class com.devexperts.qd.ng.RecordCursor
-
Returns event sequence that is associated with the current record.
- getEventSymbolByQDSymbol(String) - Method in class com.devexperts.qd.ng.RecordMapping
-
- getEventTimeSeconds() - Method in class com.devexperts.qd.ng.RecordCursor
-
Returns event time seconds value that is associated with the current record.
- getEventTimeSequence() - Method in class com.devexperts.qd.ng.RecordCursor
-
Returns event time sequence that is associated with the current record.
- getEventTimeSequence(RecordCursor) - Method in class com.devexperts.qd.qtp.AbstractQTPComposer
-
- getEventTimeSequenceAt(long) - Method in class com.devexperts.qd.ng.RecordBuffer
-
Returns event time sequence at the specified position.
- getExtra() - Method in class com.devexperts.qd.stats.QDStats.SType
-
- getFactory(DataScheme) - Static method in class com.devexperts.qd.kit.CompositeFilters
-
- getFactory() - Method in class com.devexperts.qd.qtp.AbstractMessageConnector
-
- getFactory() - Method in interface com.devexperts.qd.qtp.MessageConnector
-
Returns ApplicationConnectionFactory
that is used by this message connector.
- getFieldReplacer() - Method in class com.devexperts.qd.qtp.AbstractMessageConnector
-
- getFieldReplacer() - Method in class com.devexperts.qd.qtp.DistributorAdapter.Factory
-
Field Replacers specification for input data.
- getFieldReplacer() - Method in class com.devexperts.qd.qtp.DistributorAdapter
-
- getFieldReplacer() - Method in class com.devexperts.qd.qtp.MessageAdapter
-
Field Replacers specification.
- getFieldReplacer() - Method in interface com.devexperts.qd.qtp.MessageConnectorMBean
-
Returns configured input field replacers.
- getFilter() - Method in interface com.devexperts.qd.QDAgent.Builder
-
- getFilter() - Method in interface com.devexperts.qd.QDDistributor.Builder
-
- getFilter() - Method in class com.devexperts.qd.QDFilter.Updated
-
Returns the most recent version of
dynamic
filter.
- getFilter() - Method in class com.devexperts.qd.qtp.MessageAdapter.AbstractFactory
-
Returns current filter of this factory.
- getFlag() - Method in class com.devexperts.qd.stats.QDStats.SType
-
- getFlags() - Method in enum com.devexperts.qd.qtp.MessageType
-
- getFullKeyProperties() - Method in class com.devexperts.qd.stats.QDStats
-
Returns full key properties including all parents starting from oldest ones.
- getGetterMethod() - Method in class com.devexperts.qd.util.QDConfig.Property
-
- getHandlerState() - Method in class com.devexperts.qd.qtp.AbstractConnectionHandler
-
- getHeartbeatPeriod() - Method in class com.devexperts.qd.qtp.MessageAdapterConnectionFactory
-
Returns heartbeat period for this application protocol.
- getHeartbeatTimeout() - Method in class com.devexperts.qd.qtp.MessageAdapterConnectionFactory
-
Returns heartbeat timeout for this application protocol.
- getHistory() - Method in class com.devexperts.qd.qtp.QDEndpoint
-
- getHistoryFilter() - Method in interface com.devexperts.qd.QDCollector.Builder
-
Returns specified history filter or null
if no filter is specified.
- getHost() - Method in class com.devexperts.qd.qtp.socket.ClientSocketConnector
-
Deprecated.
- getHost() - Method in interface com.devexperts.qd.qtp.socket.ClientSocketConnectorMBean
-
- getId() - Method in interface com.devexperts.qd.DataRecord
-
Returns identifier of this record.
- getId() - Method in class com.devexperts.qd.kit.DefaultRecord
-
- getId() - Method in class com.devexperts.qd.qtp.MessageDescriptor
-
- getId() - Method in enum com.devexperts.qd.qtp.MessageType
-
Returns message identified in QTP protocol.
- getId() - Method in class com.devexperts.qd.SerialFieldType
-
- getIndex() - Method in interface com.devexperts.qd.DataField
-
Returns index of this field in its parent
DataRecord
.
- getIndex() - Method in class com.devexperts.qd.kit.AbstractDataField
-
- getInitialHeartbeatPeriod() - Method in class com.devexperts.qd.qtp.MessageAdapterConnectionFactory
-
- getInstance() - Static method in class com.devexperts.qd.ng.RecordBuffer
-
Returns instance from thread-local pool with a default mode of
RecordMode.DATA
.
- getInstance(RecordMode) - Static method in class com.devexperts.qd.ng.RecordBuffer
-
Returns instance from thread-local pool with a specified mode.
- getInstance() - Static method in class com.devexperts.qd.util.DxTimer
-
Lazy creation of a singleton instance DxTimer
- getInt(int, int) - Method in class com.devexperts.qd.DataBuffer
-
Deprecated.
Returns specified Int-field of the record by its index within this buffer.
- getInt(int) - Method in class com.devexperts.qd.ng.RecordCursor
-
Returns the value of the specified integer field for the record pointed to by this cursor.
- getInt(RecordCursor, int) - Method in class com.devexperts.qd.ng.RecordMapping
-
- getInt(DataIntField, int, String) - Method in interface com.devexperts.qd.QDTicker
-
Returns current value of specified Int-field.
- getIntCount() - Method in class com.devexperts.qd.ng.RecordCursor
-
Returns the number of integer data fields.
- getInterface() - Method in enum com.devexperts.qd.QDContract
-
- getIntersectingStripes(QDFilter) - Method in class com.devexperts.qd.kit.HashStriper
-
- getIntersectingStripes(QDFilter) - Method in class com.devexperts.qd.kit.RangeStriper
-
- getIntersectingStripes(QDFilter) - Method in interface com.devexperts.qd.SymbolStriper
-
- getIntField(int) - Method in interface com.devexperts.qd.DataRecord
-
Returns Int-field by its index within this record.
- getIntField(int) - Method in class com.devexperts.qd.kit.DefaultRecord
-
- getIntFieldCount() - Method in interface com.devexperts.qd.DataRecord
-
Returns a number of Int-fields in this record.
- getIntFieldCount() - Method in class com.devexperts.qd.kit.DefaultRecord
-
- getIntsTo(int, int[], int, int) - Method in class com.devexperts.qd.ng.RecordCursor
-
- getKeyProperties() - Method in interface com.devexperts.qd.QDAgent.Builder
-
- getKeyProperties() - Method in interface com.devexperts.qd.QDDistributor.Builder
-
- getKeyProperties() - Method in class com.devexperts.qd.stats.QDStats
-
Returns key properties that are specific to this particular instance of QDStats as
they were specified during initialization of this instance.
- getKind() - Method in class com.devexperts.qd.kit.HashFilter
-
- getKind() - Method in class com.devexperts.qd.kit.NotFilter
-
- getKind() - Method in class com.devexperts.qd.kit.PatternFilter
-
- getKind() - Method in class com.devexperts.qd.kit.RangeFilter
-
- getKind() - Method in class com.devexperts.qd.kit.RecordOnlyFilter
-
- getKind() - Method in class com.devexperts.qd.kit.SymbolSetFilter
-
- getKind() - Method in class com.devexperts.qd.QDFilter
-
Returns a kind of this filter that constrains and defines its overall behaviour.
- getLagMark() - Method in class com.devexperts.qd.qtp.HeartbeatPayload
-
- getLimit() - Method in class com.devexperts.qd.ng.RecordBuffer
-
- getLimit() - Method in class com.devexperts.qd.ng.RecordSource
-
Returns limit of this source,
which is the position of after the last record returned by
RecordSource.next()
.
- getLimit() - Method in class com.devexperts.qd.qtp.ByteArrayParser
-
Deprecated.
Returns number of bytes in the buffer.
- getLimit() - Method in class com.devexperts.qd.util.ByteArrayBuffer
-
Deprecated.
Returns this buffer's limit.
- getLocalName() - Method in interface com.devexperts.qd.DataField
-
Returns local name of this field -- the name of this field that is unique within the record
and identifies this field in QTP binary protocol.
- getLocalName() - Method in class com.devexperts.qd.kit.AbstractDataField
-
- getLocalPort() - Method in class com.devexperts.qd.qtp.AbstractServerConnector
-
- getLocalPort() - Method in interface com.devexperts.qd.qtp.ServerConnectorMBean
-
Local TCP/IP port
- getLock() - Method in class com.devexperts.qd.qtp.QDEndpoint
-
- getLock() - Method in class com.devexperts.qd.stats.QDStats
-
- getLogging() - Method in class com.devexperts.qd.qtp.AbstractMessageConnector
-
Returns Logging
instance that is tied to this MessageConnector and
includes this connector's name into the logs.
- getLogin() - Method in class com.devexperts.qd.qtp.MessageAdapterConnectionFactory
-
- getLong(int) - Method in class com.devexperts.qd.ng.RecordCursor
-
Returns the value of the specified integer field for the record pointed to by this cursor.
- getLong(RecordCursor, int) - Method in class com.devexperts.qd.ng.RecordMapping
-
- getMapping() - Method in interface com.devexperts.qd.DataRecord
-
Returns mapping for this data record or null
if there is no such mapping for this record.
- getMapping(Class<T>) - Method in interface com.devexperts.qd.DataRecord
-
Returns specified mapping for this data record or null
if there is no such mapping for this record.
- getMapping() - Method in class com.devexperts.qd.kit.DefaultRecord
-
- getMapping(Class<T>) - Method in class com.devexperts.qd.kit.DefaultRecord
-
- getMappings() - Method in interface com.devexperts.qd.DataRecord
-
Returns all mappings for this data record.
- getMappings() - Method in class com.devexperts.qd.kit.DefaultRecord
-
- getMarshalled(Object) - Static method in class com.devexperts.qd.util.MappingUtil
-
- getMaxAvailableTime(DataRecord, int, String) - Method in interface com.devexperts.qd.QDHistory
-
Returns maximal time of available records for specified parameters.
- getMaxConnections() - Method in class com.devexperts.qd.qtp.AbstractServerConnector
-
- getMaxConnections() - Method in interface com.devexperts.qd.qtp.ServerConnectorMBean
-
Max number of connections
- getMaxRecordCount(DataRecord, int, String) - Method in interface com.devexperts.qd.HistorySubscriptionFilter
-
- getMessageMask(MessageType) - Static method in class com.devexperts.qd.qtp.MessageAdapter
-
- getMessagePayloadSize() - Method in class com.devexperts.qd.qtp.AbstractQTPComposer
-
- getMessageType() - Method in class com.devexperts.qd.qtp.MessageDescriptor
-
- getMinAvailableTime(DataRecord, int, String) - Method in interface com.devexperts.qd.QDHistory
-
Returns minimal time of available records for specified parameters.
- getMinHistoryTime(DataRecord, int, String) - Method in interface com.devexperts.qd.HistorySubscriptionFilter
-
- getMode() - Method in class com.devexperts.qd.ng.AbstractRecordProvider
-
Returns record mode at which the records are provided
by
retrieve
method.
- getMode() - Method in class com.devexperts.qd.ng.RecordBuffer
-
Returns current mode of this record buffer.
- getMode() - Method in class com.devexperts.qd.ng.RecordCursor
-
Returns mode.
- getMode() - Method in interface com.devexperts.qd.ng.RecordProvider
-
Returns record mode at which the records are provided
by
retrieve
method.
- getMode() - Method in class com.devexperts.qd.ng.RecordSource
-
Returns mode of this record source.
- getMode() - Method in class com.devexperts.qd.util.CompositeRecordProvider
-
- getName() - Method in interface com.devexperts.qd.DataField
-
Returns name of this field.
- getName() - Method in interface com.devexperts.qd.DataRecord
-
Returns name of this record.
- getName() - Method in class com.devexperts.qd.kit.AbstractDataField
-
- getName() - Method in class com.devexperts.qd.kit.DefaultRecord
-
- getName() - Method in class com.devexperts.qd.kit.HashStriper
-
- getName() - Method in class com.devexperts.qd.kit.MonoStriper
-
- getName() - Method in class com.devexperts.qd.kit.RangeStriper
-
- getName() - Method in class com.devexperts.qd.qtp.AbstractMessageConnector
-
Returns short string description of this connector for management and logging purposes.
- getName() - Method in interface com.devexperts.qd.qtp.MessageConnectorMBean
-
Name of connector.
- getName() - Method in class com.devexperts.qd.qtp.MessageDescriptor
-
- getName() - Method in class com.devexperts.qd.qtp.QDEndpoint
-
- getName() - Method in class com.devexperts.qd.qtp.socket.ConnectOrder
-
- getName() - Method in class com.devexperts.qd.SerialFieldType
-
- getName() - Method in class com.devexperts.qd.stats.QDStats.SType
-
- getName() - Method in class com.devexperts.qd.stats.QDStats.SValue
-
- getName() - Method in interface com.devexperts.qd.SymbolStriper
-
Returns a string representation of this striper.
- getName() - Method in class com.devexperts.qd.util.QDConfig.Property
-
- getNewShapers() - Method in class com.devexperts.qd.qtp.AgentAdapterChannels
-
- getNonDefaultPropertyName(String) - Method in class com.devexperts.qd.ng.RecordMapping
-
- getObj(int, int) - Method in class com.devexperts.qd.DataBuffer
-
Deprecated.
Returns specified Obj-field of the record by its index within this buffer.
- getObj(int) - Method in class com.devexperts.qd.ng.RecordCursor
-
Returns the value of the specified object field for the record pointed to by this cursor.
- getObj(RecordCursor, int) - Method in class com.devexperts.qd.ng.RecordMapping
-
- getObj(DataObjField, int, String) - Method in interface com.devexperts.qd.QDTicker
-
Returns current value of specified Obj-field.
- getObjCount() - Method in class com.devexperts.qd.ng.RecordCursor
-
Returns the number of object data fields.
- getObjField(int) - Method in interface com.devexperts.qd.DataRecord
-
Returns Obj-field by its index within this record.
- getObjField(int) - Method in class com.devexperts.qd.kit.DefaultRecord
-
- getObjFieldCount() - Method in interface com.devexperts.qd.DataRecord
-
Returns a number of Obj-fields in this record.
- getObjFieldCount() - Method in class com.devexperts.qd.kit.DefaultRecord
-
- getObjsTo(int, Object[], int, int) - Method in class com.devexperts.qd.ng.RecordCursor
-
- getOrCreate(QDStats.SType) - Method in class com.devexperts.qd.stats.QDStats
-
Returns the first found child with the corresponding type or
creates
new
one if not found.
- getOrCreate(QDStats.SType, String) - Method in class com.devexperts.qd.stats.QDStats
-
Returns the first found child with the corresponding type and key properties or
creates
new one if not found.
- getOrCreateName() - Method in class com.devexperts.qd.qtp.QDEndpoint.Builder
-
- getOrCreateSum(QDStats.SType) - Method in class com.devexperts.qd.stats.QDStats
-
- getOrVoid(QDStats.SType) - Method in class com.devexperts.qd.stats.QDStats
-
Returns first found child with the corresponding type or
VOID
if not found.
- getParent() - Method in class com.devexperts.qd.stats.QDStats
-
- getPassword() - Method in class com.devexperts.qd.qtp.AbstractMessageConnector
-
- getPassword() - Method in class com.devexperts.qd.qtp.MessageAdapterConnectionFactory
-
- getPassword() - Method in interface com.devexperts.qd.qtp.MessageConnectorMBean
-
User password for authorization.
- getPattern() - Method in class com.devexperts.qd.kit.PatternFilter
-
Returns filter patter that can be always parsed back to this filter.
- getPeerFilter(QDContract) - Method in interface com.devexperts.qd.qtp.AgentChannels.Owner
-
When the channel configuration is updated, it will be summarized by logical AND with the filter that is specified
in shaper.
- getPort() - Method in class com.devexperts.qd.qtp.socket.ClientSocketConnector
-
Deprecated.
- getPort() - Method in interface com.devexperts.qd.qtp.socket.ClientSocketConnectorMBean
-
- getPosition() - Method in class com.devexperts.qd.ng.RecordBuffer
-
Returns position of the current record.
- getPosition() - Method in class com.devexperts.qd.ng.RecordCursor
-
Returns position of this cursor.
- getPosition() - Method in class com.devexperts.qd.ng.RecordSource
-
Returns position of the current record.
- getPosition() - Method in class com.devexperts.qd.util.ByteArrayBuffer
-
Deprecated.
Returns this buffer's position.
- getProcessed() - Method in class com.devexperts.qd.qtp.ByteArrayComposer
-
Deprecated.
Returns number of processed bytes ready to be sent over and removed.
- getProcessed() - Method in class com.devexperts.qd.qtp.ByteArrayParser
-
Deprecated.
Returns number of processed bytes ready to be removed.
- getProperties() - Method in class com.devexperts.qd.qtp.MessageDescriptor
-
- getProperties() - Method in class com.devexperts.qd.qtp.ProtocolDescriptor
-
- getProperties(Object) - Static method in class com.devexperts.qd.util.QDConfig
-
- getProperties(Object, Class<?>) - Static method in class com.devexperts.qd.util.QDConfig
-
- getProperties(Class<?>) - Static method in class com.devexperts.qd.util.QDConfig
-
- getProperty(String) - Method in class com.devexperts.qd.qtp.MessageDescriptor
-
- getProperty(String) - Method in class com.devexperts.qd.qtp.ProtocolDescriptor
-
- getPropertyName() - Method in interface com.devexperts.qd.DataField
-
Returns property name of this field -- the name of this field that is unique within the record
and identifies this field in QTP text formats.
- getPropertyName() - Method in class com.devexperts.qd.kit.AbstractDataField
-
- getPropertyType() - Method in class com.devexperts.qd.util.QDConfig.Property
-
- getProxyHost() - Method in class com.devexperts.qd.qtp.socket.ClientSocketConnector
-
- getProxyHost() - Method in interface com.devexperts.qd.qtp.socket.ClientSocketConnectorMBean
-
HTTP proxy host name
- getProxyPort() - Method in class com.devexperts.qd.qtp.socket.ClientSocketConnector
-
- getProxyPort() - Method in interface com.devexperts.qd.qtp.socket.ClientSocketConnectorMBean
-
HTTP proxy port
- getQDSymbolByEventSymbol(Object) - Method in class com.devexperts.qd.ng.RecordMapping
-
- getReceive(MessageType) - Method in class com.devexperts.qd.qtp.ProtocolDescriptor
-
- getReceiveMessages() - Method in class com.devexperts.qd.qtp.ProtocolDescriptor
-
- getReceiveSet() - Method in class com.devexperts.qd.qtp.ProtocolDescriptor
-
- getReconnectDelay() - Method in class com.devexperts.qd.qtp.AbstractMessageConnector
-
- getReconnectDelay() - Method in interface com.devexperts.qd.qtp.MessageConnectorMBean
-
Delay between reconnection attempts in milliseconds
- getRecord(int) - Method in class com.devexperts.qd.DataBuffer
-
Deprecated.
Returns record by its index within this buffer.
- getRecord() - Method in interface com.devexperts.qd.DataField
-
- getRecord(int) - Method in interface com.devexperts.qd.DataScheme
-
Returns data record by its index within this scheme.
- getRecord() - Method in class com.devexperts.qd.kit.AbstractDataField
-
- getRecord(int) - Method in class com.devexperts.qd.kit.DefaultScheme
-
- getRecord() - Method in class com.devexperts.qd.ng.RecordCursor
-
Returns record.
- getRecord() - Method in class com.devexperts.qd.ng.RecordMapping
-
Returns data record that this record mapping works for.
- getRecord() - Method in class com.devexperts.qd.qtp.BinaryRecordDesc
-
Returns actual DataRecord that shall be used for subscription.
- getRecord(int) - Method in class com.devexperts.qd.SubscriptionBuffer
-
Deprecated.
Returns record by its index within this buffer.
- getRecordAt(long) - Method in class com.devexperts.qd.ng.RecordBuffer
-
Returns record at the specified position.
- getRecordBufferMode(MessageType) - Method in class com.devexperts.qd.qtp.AbstractQTPParser
-
- getRecordCount() - Method in interface com.devexperts.qd.DataScheme
-
Returns number of records in this scheme.
- getRecordCount() - Method in class com.devexperts.qd.kit.DefaultScheme
-
- getRecordCounter() - Method in class com.devexperts.qd.qtp.OutputStreamComposer
-
Returns number of composed records since initialization.
- getRecordMode() - Method in enum com.devexperts.qd.qtp.MessageType
-
- getRemoteEndpointId() - Method in class com.devexperts.qd.qtp.MessageAdapter
-
- getRemoteHostAddress() - Method in class com.devexperts.qd.qtp.MessageAdapter
-
- getRemoteOptSet() - Method in class com.devexperts.qd.qtp.MessageAdapter
-
- getRemovedRecordProvider() - Method in interface com.devexperts.qd.QDDistributor
-
Returns subscription provider that is used to accumulate removed subscription.
- getRemovedSubscriptionProvider() - Method in interface com.devexperts.qd.QDDistributor
-
- getRemovingSubscriptionConsumer() - Method in interface com.devexperts.qd.QDAgent
-
- getRequestedRecordDesc(DataRecord) - Method in class com.devexperts.qd.qtp.BinaryQTPComposer
-
- getRestoreTime() - Method in class com.devexperts.qd.qtp.socket.ClientSocketConnector
-
- getRestoreTime() - Method in interface com.devexperts.qd.qtp.socket.ClientSocketConnectorMBean
-
- getResultingClass() - Method in interface com.devexperts.qd.qtp.MessageConnectorFactory
-
Returns the exact class of produced MessageConnectors.
- getRidCount() - Method in class com.devexperts.qd.stats.QDStats
-
- getRootStats() - Method in class com.devexperts.qd.qtp.QDEndpoint
-
- getScheme() - Method in interface com.devexperts.qd.DataRecord
-
- getScheme() - Method in class com.devexperts.qd.kit.DefaultRecord
-
- getScheme() - Method in class com.devexperts.qd.kit.HashStriper
-
- getScheme() - Method in class com.devexperts.qd.kit.MonoStriper
-
- getScheme() - Method in class com.devexperts.qd.kit.RangeStriper
-
- getScheme() - Method in interface com.devexperts.qd.QDCollector.Builder
-
Returns specified scheme.
- getScheme() - Method in interface com.devexperts.qd.QDCollector
-
Returns data scheme used by this QD component.
- getScheme() - Method in class com.devexperts.qd.QDFilter
-
Returns scheme that this filter works for.
- getScheme() - Method in class com.devexperts.qd.qtp.AgentAdapter
-
- getScheme() - Method in class com.devexperts.qd.qtp.DistributorAdapter
-
- getScheme() - Method in class com.devexperts.qd.qtp.fieldreplacer.FieldReplacersCache
-
- getScheme() - Method in class com.devexperts.qd.qtp.MessageAdapter.AbstractFactory
-
- getScheme() - Method in class com.devexperts.qd.qtp.MessageAdapter
-
- getScheme() - Method in class com.devexperts.qd.qtp.QDEndpoint
-
- getScheme() - Method in class com.devexperts.qd.spi.QDFilterFactory
-
Returns data scheme of this filter factory.
- getScheme() - Method in class com.devexperts.qd.spi.SymbolStriperFactory
-
Returns data scheme of this filter factory.
- getScheme() - Method in class com.devexperts.qd.stats.QDStats
-
- getScheme() - Method in interface com.devexperts.qd.SymbolStriper
-
Returns scheme that this striper works for.
- getSchemeOrDefault() - Method in class com.devexperts.qd.qtp.QDEndpoint.Builder
-
- getSend(MessageType) - Method in class com.devexperts.qd.qtp.ProtocolDescriptor
-
- getSendMessages() - Method in class com.devexperts.qd.qtp.ProtocolDescriptor
-
- getSendSet() - Method in class com.devexperts.qd.qtp.ProtocolDescriptor
-
- getSequenceFromTimeSequence(long) - Static method in class com.devexperts.qd.util.TimeSequenceUtil
-
Returns sequence from time sequence value.
- getSerialType() - Method in interface com.devexperts.qd.DataField
-
Returns serial type of this field.
- getSerialType() - Method in class com.devexperts.qd.kit.AbstractDataField
-
- getService(Class<T>) - Method in interface com.devexperts.qd.DataScheme
-
Extension point for additional scheme-specific services.
- getService(Class<T>) - Method in class com.devexperts.qd.kit.DefaultScheme
-
- getSetterMethod() - Method in class com.devexperts.qd.util.QDConfig.Property
-
- getShift() - Method in class com.devexperts.qd.kit.HashStriper
-
- getSnapshotProvider() - Method in interface com.devexperts.qd.QDAgent
-
Returns record provider that is used to retrieve only snapshot from Ticker and History.
- getSpec() - Method in class com.devexperts.qd.qtp.fieldreplacer.FieldReplacersCache
-
- getState() - Method in interface com.devexperts.qd.qtp.MessageConnectorMBean
-
State of connector.
- getState() - Method in class com.devexperts.qd.qtp.socket.ClientSocketConnector
-
- getState() - Method in class com.devexperts.qd.qtp.socket.ServerSocketConnector
-
- getStats() - Method in interface com.devexperts.qd.QDCollector.Builder
-
Returns specified stats.
- getStats() - Method in class com.devexperts.qd.qtp.AbstractMessageConnector
-
- getStats() - Method in class com.devexperts.qd.qtp.MessageAdapter
-
- getStats() - Method in interface com.devexperts.qd.qtp.MessageConnector
-
Returns
QDStats
associated with this message connector.
- getStats() - Method in interface com.devexperts.qd.stats.QDStatsContainer
-
- getStatsType() - Method in interface com.devexperts.qd.QDCollector.Factory
-
Returns type of the stats stat should be used for collector created by this factory.
- getStatsType() - Method in enum com.devexperts.qd.QDContract
-
- getStatus() - Method in class com.devexperts.qd.qtp.MessageAdapter
-
- getStoreEverythingFilter() - Method in interface com.devexperts.qd.QDCollector.Builder
-
Returns filter to be used for "story everything" feature.
- getStream() - Method in class com.devexperts.qd.qtp.QDEndpoint
-
- getStride() - Method in class com.devexperts.qd.stats.QDStats.SType
-
- getString(RecordCursor) - Method in interface com.devexperts.qd.DataField
-
- getString(RecordCursor) - Method in class com.devexperts.qd.kit.AbstractDataIntField
-
- getString(RecordCursor) - Method in class com.devexperts.qd.kit.AbstractDataObjField
-
- getString(RecordCursor) - Method in class com.devexperts.qd.kit.LongField
-
- getString(RecordCursor) - Method in class com.devexperts.qd.kit.TimeMillisField
-
- getString(RecordCursor) - Method in class com.devexperts.qd.kit.VoidIntField
-
- getString(RecordCursor) - Method in class com.devexperts.qd.kit.WideDecimalField
-
- getStripe() - Method in interface com.devexperts.qd.QDAgent.Builder
-
- getStripe() - Method in interface com.devexperts.qd.QDDistributor.Builder
-
- getStripe() - Method in class com.devexperts.qd.qtp.MessageAdapter.AbstractFactory
-
- getStripe() - Method in class com.devexperts.qd.qtp.socket.ClientSocketConnector
-
- getStripe() - Method in interface com.devexperts.qd.qtp.socket.ClientSocketConnectorMBean
-
Symbol striper for connector, auto (for system default), or null (default)
- getStripeCount() - Method in class com.devexperts.qd.kit.HashStriper
-
- getStripeCount() - Method in class com.devexperts.qd.kit.MonoStriper
-
- getStripeCount() - Method in class com.devexperts.qd.kit.RangeStriper
-
- getStripeCount() - Method in interface com.devexperts.qd.SymbolStriper
-
Returns the positive number of stripes that this striper splits into.
- getStripeFilter(int) - Method in class com.devexperts.qd.kit.HashStriper
-
- getStripeFilter(int) - Method in class com.devexperts.qd.kit.MonoStriper
-
- getStripeFilter(int) - Method in class com.devexperts.qd.kit.RangeStriper
-
- getStripeFilter() - Method in class com.devexperts.qd.qtp.MessageAdapter.AbstractFactory
-
- getStripeFilter(int) - Method in interface com.devexperts.qd.SymbolStriper
-
Returns
filter
corresponding for the given stripe index.
- getStripeIndex(int, String) - Method in class com.devexperts.qd.kit.HashStriper
-
- getStripeIndex(String) - Method in class com.devexperts.qd.kit.HashStriper
-
- getStripeIndex(char[], int, int) - Method in class com.devexperts.qd.kit.HashStriper
-
- getStripeIndex(int, String) - Method in class com.devexperts.qd.kit.MonoStriper
-
- getStripeIndex(String) - Method in class com.devexperts.qd.kit.MonoStriper
-
- getStripeIndex(char[], int, int) - Method in class com.devexperts.qd.kit.MonoStriper
-
- getStripeIndex(int, String) - Method in class com.devexperts.qd.kit.RangeStriper
-
- getStripeIndex(String) - Method in class com.devexperts.qd.kit.RangeStriper
-
- getStripeIndex(char[], int, int) - Method in class com.devexperts.qd.kit.RangeStriper
-
- getStripeIndex(int, String) - Method in interface com.devexperts.qd.SymbolStriper
-
Returns the index of the stripe that the given cipher-symbol pair falls into.
- getStripeIndex(String) - Method in interface com.devexperts.qd.SymbolStriper
-
Returns the index of the stripe that the given symbol falls into.
- getStripeIndex(char[], int, int) - Method in interface com.devexperts.qd.SymbolStriper
-
Returns the index of the stripe that the given symbol (represented as character array) falls into.
- getStriper() - Method in interface com.devexperts.qd.QDCollector.Builder
-
Returns symbol striper for collector.
- getStriper() - Method in interface com.devexperts.qd.QDCollector
-
Returns symbol striper for this QD component.
- getStriperOrDefault() - Method in class com.devexperts.qd.qtp.QDEndpoint.Builder
-
- getSubscriptionExecutor() - Method in class com.devexperts.qd.qtp.AgentAdapter.Factory
-
- getSubscriptionExecutor() - Method in class com.devexperts.qd.qtp.ChannelShaper
-
Returns executor for subscription processing used by the channel
or null
if none specified.
- getSubscriptionFilter() - Method in class com.devexperts.qd.qtp.ChannelShaper
-
Returns subscription filter currently used by the channel.
- getSubscriptionKeepAlive() - Method in class com.devexperts.qd.qtp.AgentAdapter.Factory
-
- getSubscriptionSize() - Method in interface com.devexperts.qd.SubscriptionContainer
-
Returns subscription size in terms of (record, symbol) pairs.
- getSubscriptionThreads() - Method in class com.devexperts.qd.qtp.AgentAdapter.Factory
-
- getSuffix() - Method in class com.devexperts.qd.util.QDConfig.Property
-
- getSupportedEventFlags(ProtocolOption.Set, MessageType) - Static method in enum com.devexperts.qd.ng.EventFlag
-
Returns a mask of supported event flags for a given set of protocol options and message type.
- getSymbol(int) - Method in class com.devexperts.qd.DataBuffer
-
Deprecated.
Returns symbol of the record by its index within this buffer.
- getSymbol() - Method in class com.devexperts.qd.DataBuffer
-
Deprecated.
- getSymbol() - Method in interface com.devexperts.qd.DataIterator
-
- getSymbol() - Method in class com.devexperts.qd.ng.RecordBuffer
-
- getSymbol() - Method in class com.devexperts.qd.ng.RecordCursor
-
Returns symbol or
null
if symbol is coded in
cipher
.
- getSymbol() - Method in class com.devexperts.qd.ng.RecordSource
-
- getSymbol(char[], int, int) - Method in interface com.devexperts.qd.QDCollector
-
- getSymbol(char[], int, int) - Method in class com.devexperts.qd.qtp.AgentAdapter
-
- getSymbol(char[], int, int) - Method in class com.devexperts.qd.qtp.DistributorAdapter
-
- getSymbol(char[], int, int) - Method in class com.devexperts.qd.qtp.MessageConsumerAdapter
-
Returns symbol used for specified characters or null
if not found.
- getSymbol(int) - Method in class com.devexperts.qd.SubscriptionBuffer
-
Deprecated.
Returns symbol of the record by its index within this buffer.
- getSymbol() - Method in class com.devexperts.qd.SubscriptionBuffer
-
Deprecated.
- getSymbol() - Method in interface com.devexperts.qd.SubscriptionIterator
-
- getSymbol() - Method in class com.devexperts.qd.SymbolCodec.Reader
-
- getSymbol(char[], int, int) - Method in interface com.devexperts.qd.SymbolCodec.Resolver
-
Returns symbol used for specified characters or null
if not found.
- getSymbol(int) - Method in class com.devexperts.qd.SymbolList
-
- getSymbol(char[], int, int) - Method in class com.devexperts.qd.util.SymbolObjectMap
-
Returns symbol used for specified characters or null
if not found.
- getSymbol(char[], int, int) - Method in class com.devexperts.qd.util.SymbolSet
-
Returns symbol used for specified characters or null
if not found.
- getSymbol(char[], int, int) - Method in class com.devexperts.qd.util.SymbolSet.ListSet
-
- getSymbolAt(long) - Method in class com.devexperts.qd.ng.RecordBuffer
-
Returns symbol at the specified position.
- getSymbolSet() - Method in class com.devexperts.qd.kit.PatternFilter
-
- getSymbolSet() - Method in class com.devexperts.qd.kit.SymbolSetFilter
-
- getSymbolSet() - Method in class com.devexperts.qd.QDFilter
-
Returns a set of symbols that corresponds to this filter.
- getSyntaxPrecedence() - Method in class com.devexperts.qd.kit.SymbolSetFilter
-
- getSyntaxPrecedence() - Method in class com.devexperts.qd.QDFilter
-
- getThreadPriority() - Method in class com.devexperts.qd.qtp.AbstractMessageConnector
-
- getThreadPriority() - Method in interface com.devexperts.qd.qtp.MessageConnectorMBean
-
Priority for threads associated with this connector
- getTicker() - Method in class com.devexperts.qd.qtp.QDEndpoint
-
- getTime(int) - Method in class com.devexperts.qd.DataBuffer
-
Deprecated.
Returns time of the record given by its index within this buffer.
- getTime() - Method in class com.devexperts.qd.ng.RecordBuffer
-
- getTime() - Method in class com.devexperts.qd.ng.RecordCursor
-
Returns time of this record that is a long value composed of the value of the first two integer fields.
- getTime() - Method in class com.devexperts.qd.ng.RecordSource
-
- getTime(int) - Method in class com.devexperts.qd.SubscriptionBuffer
-
Deprecated.
Returns time of the record by its index within this buffer.
- getTime() - Method in class com.devexperts.qd.SubscriptionBuffer
-
Deprecated.
- getTime() - Method in interface com.devexperts.qd.SubscriptionIterator
-
- getTimeMark() - Method in class com.devexperts.qd.ng.RecordCursor
-
Returns time mark that is associated with the current record.
- getTimeMark() - Method in class com.devexperts.qd.qtp.HeartbeatPayload
-
- getTimeMillis() - Method in class com.devexperts.qd.qtp.HeartbeatPayload
-
- getTimeMillisFromTimeSequence(long) - Static method in class com.devexperts.qd.util.TimeSequenceUtil
-
Returns time millis from time sequence.
- getTimeSecondsFromTimeSequence(long) - Static method in class com.devexperts.qd.util.TimeSequenceUtil
-
Returns time in seconds from time sequence value.
- getTimeSequenceFromTimeMillis(long) - Static method in class com.devexperts.qd.util.TimeSequenceUtil
-
Returns time sequence from time millis.
- getTimeSequenceFromTimeSecondsAndSequence(int, int) - Static method in class com.devexperts.qd.util.TimeSequenceUtil
-
Converts time seconds and sequence ints into a time sequence long.
- getTimeZone() - Method in class com.devexperts.qd.util.TimeFormat
-
Deprecated.
Returns default timezone of current TimeFormat.
- getTls() - Method in class com.devexperts.qd.qtp.socket.ClientSocketConnector
-
Deprecated.
- getTls() - Method in class com.devexperts.qd.qtp.socket.ServerSocketConnector
-
- getTrustManager() - Method in class com.devexperts.qd.qtp.socket.ClientSocketConnector
-
Deprecated.
- getType() - Method in class com.devexperts.qd.stats.QDStats
-
Returns type of this statistics instance.
- getUncodedCount() - Method in class com.devexperts.qd.SymbolList
-
- getUpdated() - Method in class com.devexperts.qd.QDFilter
-
Returns an object that tracks the most-recent version of the
dynamic
filter.
- getUpdatedFilter() - Method in class com.devexperts.qd.QDFilter
-
Returns new value of this filter if this is a
dynamic
filter that has updated.
- getUser() - Method in class com.devexperts.qd.qtp.AbstractMessageConnector
-
- getUser() - Method in class com.devexperts.qd.qtp.MessageAdapterConnectionFactory
-
- getUser() - Method in interface com.devexperts.qd.qtp.MessageConnectorMBean
-
User login name
Returns connector's user name for authorization.
- getValue(QDStats.SValue) - Method in class com.devexperts.qd.stats.QDStats
-
- getValue(QDStats.SValue, boolean) - Method in class com.devexperts.qd.stats.QDStats
-
- getValue(int) - Static method in class com.devexperts.qd.stats.QDStats.SValue
-
- getValueCount() - Static method in class com.devexperts.qd.stats.QDStats.SValue
-
- getVersion() - Static method in class com.devexperts.qd.QDFactory
-
Returns string description of this QDS version.
- getWeight() - Method in class com.devexperts.qd.qtp.ChannelShaper
-
Returns relative weight of this channel data within the adapter for shaping.
- getWildcardCipher() - Method in class com.devexperts.qd.kit.PentaCodec
-
Returns cipher that is used by the "wildcard" symbol, this implementation returns value that
is equal to encode("*")
.
- getWildcardCipher() - Method in interface com.devexperts.qd.SymbolCodec
-
Returns cipher that is used by the "wildcard" symbol.
- GMT - Static variable in class com.devexperts.qd.util.TimeFormat
-
- GRACEFUL_DELAY - Static variable in class com.devexperts.qd.qtp.QTPConstants
-
Defines the graceful delay for different socket activities
- growLength(int, int) - Static method in class com.devexperts.qd.DataBuffer
-
Deprecated.
Grows length twice until it is larger than size.
- id - Variable in class com.devexperts.qd.kit.DefaultRecord
-
- ID_BYTE - Static variable in class com.devexperts.qd.SerialFieldType.Bits
-
- ID_BYTE_ARRAY - Static variable in class com.devexperts.qd.SerialFieldType.Bits
-
- ID_COMPACT_INT - Static variable in class com.devexperts.qd.SerialFieldType.Bits
-
- ID_INT - Static variable in class com.devexperts.qd.SerialFieldType.Bits
-
- ID_SHORT - Static variable in class com.devexperts.qd.SerialFieldType.Bits
-
- ID_UTF_CHAR - Static variable in class com.devexperts.qd.SerialFieldType.Bits
-
- ID_UTF_CHAR_ARRAY - Static variable in class com.devexperts.qd.SerialFieldType.Bits
-
- ID_VOID - Static variable in class com.devexperts.qd.SerialFieldType.Bits
-
- in(int) - Method in enum com.devexperts.qd.ng.EventFlag
-
- in - Variable in class com.devexperts.qd.qtp.ByteArrayParser
-
Deprecated.
Exposed input for backwards compatibility with code that invokes in.setBuffer
to parse array of bytes.
- incrementCombines(T) - Method in class com.devexperts.qd.kit.ArrayListAttachmentStrategy
-
- index - Variable in class com.devexperts.qd.kit.HashFilter
-
- index(int, int) - Static method in class com.devexperts.qd.kit.HashStriper
-
- INDEX_MASK - Static variable in class com.devexperts.qd.qtp.BinaryRecordDesc
-
- init(InputStream) - Method in class com.devexperts.qd.qtp.InputStreamParser
-
Initializes parser with a specified input stream.
- init(OutputStream, SubscriptionFilter) - Method in class com.devexperts.qd.qtp.OutputStreamComposer
-
Initializes composer with a specified output stream and subscription filter parameters.
- initChild(QDStats, QDStats.SType, String, int, DataScheme) - Method in class com.devexperts.qd.stats.QDStats
-
- initialize(ChannelShaper...) - Method in class com.devexperts.qd.qtp.AgentAdapter
-
Initializes the adapter with specified channel shapers.
- initializeConnectorsForAddress(String) - Method in class com.devexperts.qd.qtp.QDEndpoint
-
Initializes endpoint's connectors to the specified address(es).
- initRoot(QDStats.SType, int) - Method in class com.devexperts.qd.stats.QDStats
-
- initRoot(QDStats.SType, DataScheme) - Method in class com.devexperts.qd.stats.QDStats
-
Initializes root statistics after instantiation using no-arg constructor.
- initStats(QDStats, QDStats.StatsLock, QDStats.SType, DataScheme) - Method in class com.devexperts.qd.stats.QDStats
-
Deprecated.
- inMessage() - Method in class com.devexperts.qd.qtp.AbstractQTPComposer
-
Returns true if we are within a message and false if not.
- InputStreamParser - Class in com.devexperts.qd.qtp
-
This parser reads and filters data and subscription from a specified
InputStream
in binary QTP format.
- InputStreamParser(DataScheme) - Constructor for class com.devexperts.qd.qtp.InputStreamParser
-
Creates parser for the specified data scheme.
- INSTANCE - Static variable in class com.devexperts.qd.kit.MonoStriper
-
- INSTANCE - Static variable in class com.devexperts.qd.kit.PentaCodec
-
The instance of PentaCodec
.
- INSTANCE - Static variable in class com.devexperts.qd.qtp.auth.BasicAuthRealmFactory
-
- INSTANCE - Static variable in class com.devexperts.qd.qtp.auth.BasicChannelShaperFactory
-
- INSTANCE - Static variable in class com.devexperts.qd.qtp.auth.BasicLoginHandlerFactory
-
- INT - Static variable in class com.devexperts.qd.SerialFieldType
-
- intersectStripes(QDFilter, QDFilter) - Static method in class com.devexperts.qd.qtp.MessageAdapter
-
- intValue() - Method in class com.devexperts.qd.util.Decimal
-
- InvalidFormatException - Exception in com.devexperts.qd.util
-
- InvalidFormatException(String) - Constructor for exception com.devexperts.qd.util.InvalidFormatException
-
Deprecated.
- InvalidFormatException(String, Throwable) - Constructor for exception com.devexperts.qd.util.InvalidFormatException
-
Deprecated.
- IO_DATA_READ_LAGS - Static variable in class com.devexperts.qd.stats.QDStats.SValue
-
- IO_DATA_READ_RECORDS - Static variable in class com.devexperts.qd.stats.QDStats.SValue
-
- IO_DATA_WRITE_LAGS - Static variable in class com.devexperts.qd.stats.QDStats.SValue
-
- IO_DATA_WRITE_RECORDS - Static variable in class com.devexperts.qd.stats.QDStats.SValue
-
- IO_EXTRA - Static variable in class com.devexperts.qd.stats.QDStats
-
- IO_READ_BYTES - Static variable in class com.devexperts.qd.stats.QDStats.SValue
-
- IO_READ_RTTS - Static variable in class com.devexperts.qd.stats.QDStats.SValue
-
- IO_STRIDE - Static variable in class com.devexperts.qd.stats.QDStats
-
- IO_SUB_READ_RECORDS - Static variable in class com.devexperts.qd.stats.QDStats.SValue
-
- IO_SUB_WRITE_RECORDS - Static variable in class com.devexperts.qd.stats.QDStats.SValue
-
- IO_WRITE_BYTES - Static variable in class com.devexperts.qd.stats.QDStats.SValue
-
- IO_WRITE_RTTS - Static variable in class com.devexperts.qd.stats.QDStats.SValue
-
- isAccepting() - Method in interface com.devexperts.qd.qtp.ServerConnectorMBean
-
Checks whether the connection can be accepted
- isAccepting() - Method in class com.devexperts.qd.qtp.socket.ServerSocketConnector
-
- isActive() - Method in class com.devexperts.qd.qtp.AbstractServerConnector
-
- isActive() - Method in interface com.devexperts.qd.qtp.MessageConnectorMBean
-
True when connector is active (started).
- isActive() - Method in class com.devexperts.qd.qtp.socket.ClientSocketConnector
-
- isAlive() - Method in class com.devexperts.qd.qtp.MessageAdapter
-
Returns
true
when this message adapter is alive
(was
started
and was not
closed
yet).
- isAlive() - Method in interface com.devexperts.qd.qtp.MessageAdapterMBean
-
- isAvailable(DataRecord, int, String) - Method in interface com.devexperts.qd.QDTicker
-
Determines if value of specified record is available.
- isCapacityLimited() - Method in class com.devexperts.qd.ng.RecordBuffer
-
Returns true
when this record buffer is capacity-limited.
- isClosed() - Method in class com.devexperts.qd.qtp.AbstractMessageConnector
-
- isClosed() - Method in class com.devexperts.qd.qtp.MessageAdapter
-
- isClosed() - Method in class com.devexperts.qd.qtp.QDEndpoint
-
- isClosed() - Method in class com.devexperts.qd.qtp.QTPWorkerThread
-
Returns true
if thread is closed and clears interrupt flag.
- isCollectionOf(QDStats.SType) - Method in class com.devexperts.qd.stats.QDStats.SType
-
- isData() - Method in enum com.devexperts.qd.qtp.MessageType
-
- isDataIdenticalTo(RecordCursor) - Method in class com.devexperts.qd.ng.RecordCursor
-
Returns true
when data contents of this cursor are equal (identity-wise) to the contents
of the other cursor.
- isDecimal() - Method in class com.devexperts.qd.SerialFieldType
-
- isDynamic() - Method in class com.devexperts.qd.kit.NotFilter
-
- isDynamic() - Method in class com.devexperts.qd.kit.RecordOnlyFilter
-
This final implementation always returns false
.
- isDynamic() - Method in class com.devexperts.qd.kit.SymbolSetFilter
-
- isDynamic() - Method in class com.devexperts.qd.QDFilter
-
Returns true
if this filter is dynamic, that is it can update and send the corresponding
notification.
- isEmpty() - Method in class com.devexperts.qd.DataBuffer
-
Deprecated.
Returns true
if this data buffer has no records.
- isEmpty() - Method in class com.devexperts.qd.ng.RecordBuffer
-
Returns
true
when this buffer is empty,
that is when its
size
is zero.
- isEmpty() - Method in class com.devexperts.qd.qtp.BinaryRecordDesc
-
Returns true when this descriptor was originally empty (did not contain any fields) as opposed to
having an empty intersection with fields in the scheme.
- isEmpty() - Method in class com.devexperts.qd.qtp.HeartbeatPayload
-
- isEmpty() - Method in class com.devexperts.qd.SubscriptionBuffer
-
Deprecated.
Returns true
if this subscription buffer has no records.
- isEmpty() - Method in class com.devexperts.qd.util.SymbolObjectMap
-
- isEmpty() - Method in class com.devexperts.qd.util.SymbolSet
-
- isFast() - Method in class com.devexperts.qd.kit.HashFilter
-
- isFast() - Method in class com.devexperts.qd.kit.NotFilter
-
- isFast() - Method in class com.devexperts.qd.kit.PatternFilter
-
- isFast() - Method in class com.devexperts.qd.kit.RangeFilter
-
- isFast() - Method in class com.devexperts.qd.kit.RecordOnlyFilter
-
This final implementation always returns true
.
- isFast() - Method in class com.devexperts.qd.kit.SymbolSetFilter
-
- isFast() - Method in class com.devexperts.qd.QDFilter
-
Returns true
if this filter is fast, that is it can be quickly checked without blocking.
- isHistory() - Method in enum com.devexperts.qd.qtp.MessageType
-
- isHistorySubscriptionAdd() - Method in enum com.devexperts.qd.qtp.MessageType
-
- isInfinite(int) - Static method in class com.devexperts.qd.util.Decimal
-
- isIOType() - Method in class com.devexperts.qd.stats.QDStats.SType
-
- isKeepRejected() - Method in class com.devexperts.qd.qtp.ChannelShaper
-
Returns true
when subscription rejected by this channel's filter is kept for
the case of future changes of subscription filter.
- isLong() - Method in class com.devexperts.qd.SerialFieldType
-
- isMarkedForImmediateRestart() - Method in class com.devexperts.qd.qtp.MessageAdapter
-
Returns true
if this message adapter was marked for immediate restart by underlying
connection when it is closed.
- isMem() - Method in class com.devexperts.qd.stats.QDStats.SValue
-
- isMemType() - Method in class com.devexperts.qd.stats.QDStats.SType
-
- isNaN(int) - Static method in class com.devexperts.qd.util.Decimal
-
- isNewConnectionAllowed() - Method in class com.devexperts.qd.qtp.socket.ServerSocketConnector
-
- isObject() - Method in class com.devexperts.qd.SerialFieldType
-
- isProtocolDescriptorCompatible(ProtocolDescriptor) - Method in class com.devexperts.qd.qtp.AgentAdapter
-
- isProtocolDescriptorCompatible(ProtocolDescriptor) - Method in class com.devexperts.qd.qtp.DistributorAdapter
-
- isProtocolDescriptorCompatible(ProtocolDescriptor) - Method in class com.devexperts.qd.qtp.MessageAdapter
-
- isReadOnly() - Method in class com.devexperts.qd.ng.RecordCursor
-
Returns true
if this cursor is in read-only mode.
- isRecordOnly() - Method in enum com.devexperts.qd.QDFilter.Kind
-
Returns true
for filters that depend only on the the record.
- isRid() - Method in class com.devexperts.qd.stats.QDStats.SValue
-
- isRidType() - Method in class com.devexperts.qd.stats.QDStats.SType
-
- isRMIAds() - Method in enum com.devexperts.qd.qtp.MessageType
-
- isRMIChan() - Method in enum com.devexperts.qd.qtp.MessageType
-
- isRMIReq() - Method in enum com.devexperts.qd.qtp.MessageType
-
- isRMIRes() - Method in enum com.devexperts.qd.qtp.MessageType
-
- isSameAs(QDStats.SType) - Method in class com.devexperts.qd.stats.QDStats.SType
-
Returns true
if the given type is "same" (i.e.
- isSchemeKnown() - Method in class com.devexperts.qd.qtp.BinaryQTPParser
-
- isSchemeKnown() - Method in class com.devexperts.qd.qtp.ByteArrayParser
-
Deprecated.
- isStable() - Method in class com.devexperts.qd.kit.NotFilter
-
- isStable() - Method in class com.devexperts.qd.kit.RecordOnlyFilter
-
This final implementation always returns true
.
- isStable() - Method in class com.devexperts.qd.QDFilter
-
Returns
true
if this filter is
stable, that is the decision of its
accept
method never changes for a given set of
arguments even from restart to restart and from one JVM to another.
- isStoreEverything() - Method in interface com.devexperts.qd.QDCollector.Builder
-
Returns true if collector should work in "story everything" mode.
- isStoreEverything() - Method in interface com.devexperts.qd.QDCollector
-
Returns status of "store everything" mode.
- isStream() - Method in enum com.devexperts.qd.qtp.MessageType
-
- isSubscribed(DataRecord, int, String, long) - Method in interface com.devexperts.qd.SubscriptionContainer
-
Returns true
if subscribed to the corresponding record and symbol with the
corresponding time.
- isSubscription() - Method in enum com.devexperts.qd.qtp.MessageType
-
- isSubscriptionAdd() - Method in enum com.devexperts.qd.qtp.MessageType
-
- isSubscriptionRemove() - Method in enum com.devexperts.qd.qtp.MessageType
-
- isSubsetOf(RecordMode) - Method in class com.devexperts.qd.ng.RecordMode
-
Returns true
when this mode is the same or represents a subset of information from the other mode.
- isSum() - Method in class com.devexperts.qd.stats.QDStats
-
- isSumFor(QDStats) - Method in class com.devexperts.qd.stats.QDStats
-
- isSymbolOnly() - Method in enum com.devexperts.qd.QDFilter.Kind
-
Returns true
for filters that depend only on the the symbol.
- isTime() - Method in class com.devexperts.qd.SerialFieldType
-
- isUnlinked() - Method in class com.devexperts.qd.ng.RecordCursor
-
- isValidRangeChar(char) - Static method in class com.devexperts.qd.kit.RangeUtil
-
- isWideDecimalSupported() - Method in class com.devexperts.qd.qtp.BinaryQTPComposer
-
- iterator() - Method in class com.devexperts.qd.qtp.ProtocolOption.Set
-
- parse(MessageConsumer) - Method in class com.devexperts.qd.qtp.AbstractQTPParser
-
Parses accumulated bytes and submits parsed messages to the specified MessageConsumer.
- parseAddressList(String, int) - Static method in class com.devexperts.qd.qtp.socket.SocketUtil
-
Parses a list of comma-separated host names pairs with optional port and with support
of IPv6 numeric addresses in square brackets.
- parseAddressList(String) - Static method in class com.devexperts.qd.qtp.socket.SocketUtil
-
Parses a list of comma-separated host names pairs with optional port and with support
of IPv6 numeric addresses in square brackets.
- parseAgentChannelDescription(String) - Static method in class com.devexperts.qd.qtp.auth.BasicAuthRealmFactory
-
- parseDateTime(String) - Method in class com.devexperts.qd.util.TimeFormat
-
- parseDecimal(String) - Static method in class com.devexperts.qd.util.Decimal
-
Parses string into a packed decimal integer.
- parseDecimal(char[], int, int) - Static method in class com.devexperts.qd.util.Decimal
-
- parseEventFlags(String, MessageType) - Static method in enum com.devexperts.qd.ng.EventFlag
-
Parses string set of event flags.
- parseFrom(BufferedInput) - Method in class com.devexperts.qd.qtp.HeartbeatPayload
-
Parses heartbeat payload from compact binary format.
- parseFrom(BufferedInput) - Method in class com.devexperts.qd.qtp.ProtocolDescriptor
-
- parseImpl(BufferedInput, MessageConsumer) - Method in class com.devexperts.qd.qtp.AbstractQTPParser
-
- parseImpl(BufferedInput, MessageConsumer) - Method in class com.devexperts.qd.qtp.BinaryQTPParser
-
- parseProperties(String, Collection<String>) - Static method in class com.devexperts.qd.util.QDConfig
-
Parses additional properties at the end of the given description string.
- parseProtocolOptions(String) - Static method in enum com.devexperts.qd.qtp.ProtocolOption
-
Parses string set of options.
- parseString(String) - Method in interface com.devexperts.qd.DataIntField
-
Parses string representation of specified field value.
- parseString(String) - Method in interface com.devexperts.qd.DataObjField
-
Parses string representation of specified field value.
- parseString(String) - Method in class com.devexperts.qd.kit.AbstractDataIntField
-
Parses string representation of specified field value.
- parseString(String) - Method in class com.devexperts.qd.kit.AbstractDataObjField
-
Parses string representation of specified field value.
- parseString(String) - Method in class com.devexperts.qd.kit.ByteArrayField
-
- parseString(String) - Method in class com.devexperts.qd.kit.CompactCharField
-
- parseString(String) - Method in class com.devexperts.qd.kit.DateField
-
- parseString(String) - Method in class com.devexperts.qd.kit.DecimalField
-
- parseString(String) - Method in class com.devexperts.qd.kit.LongField
-
- parseString(String) - Method in class com.devexperts.qd.kit.MarshalledObjField
-
- parseString(String) - Method in class com.devexperts.qd.kit.SequenceField
-
- parseString(String) - Method in class com.devexperts.qd.kit.ShortStringField
-
- parseString(String) - Method in class com.devexperts.qd.kit.TimeField
-
Deprecated.
- parseString(String) - Method in class com.devexperts.qd.kit.TimeMillisField
-
- parseString(String) - Method in class com.devexperts.qd.kit.WideDecimalField
-
- parseStringLong(String) - Method in class com.devexperts.qd.kit.LongField
-
- parseStringLong(String) - Method in class com.devexperts.qd.kit.TimeMillisField
-
- password(String) - Method in class com.devexperts.qd.qtp.QDEndpoint
-
- PASSWORD_CONFIGURATION_KEY - Static variable in class com.devexperts.qd.qtp.MessageConnectors
-
- PatternFilter - Class in com.devexperts.qd.kit
-
SubscriptionFilter
that understands a simple GLOB-like grammar
to specify matching symbols.
- PentaCodec - Class in com.devexperts.qd.kit
-
The PentaCodec
performs symbol coding and serialization using
extensible 5-bit encoding.
- PentaCodec() - Constructor for class com.devexperts.qd.kit.PentaCodec
-
- PlainIntField - Class in com.devexperts.qd.kit
-
The PlainIntField
represents an integer field with plain serialized form.
- PlainIntField(int, String) - Constructor for class com.devexperts.qd.kit.PlainIntField
-
- PlainIntField(int, String, SerialFieldType) - Constructor for class com.devexperts.qd.kit.PlainIntField
-
- PlainObjField - Class in com.devexperts.qd.kit
-
- PlainObjField(int, String) - Constructor for class com.devexperts.qd.kit.PlainObjField
-
Deprecated.
- Plugin() - Constructor for class com.devexperts.qd.qtp.QDEndpoint.Plugin
-
- pooledBuffer - Variable in class com.devexperts.qd.qtp.ByteArrayComposer
-
Deprecated.
- port - Variable in class com.devexperts.qd.qtp.AbstractServerConnector
-
- port - Variable in class com.devexperts.qd.qtp.socket.SocketAddress
-
- position - Variable in class com.devexperts.qd.util.ByteArrayBuffer
-
Deprecated.
- POSITIVE_INFINITY - Static variable in class com.devexperts.qd.util.Decimal
-
- POSITIVE_INFINITY_STRING - Static variable in class com.devexperts.qd.util.Decimal
-
- PREFIX_LENGTH - Static variable in class com.devexperts.qd.kit.RangeStriper
-
- prepareAuthenticateProtocolDescriptor(ProtocolDescriptor) - Method in class com.devexperts.qd.qtp.MessageAdapter
-
- prepareProtocolDescriptor(ProtocolDescriptor) - Method in class com.devexperts.qd.qtp.AgentAdapter
-
- prepareProtocolDescriptor(ProtocolDescriptor) - Method in class com.devexperts.qd.qtp.DistributorAdapter
-
- prepareProtocolDescriptor(ProtocolDescriptor) - Method in class com.devexperts.qd.qtp.MessageAdapter
-
Prepares outgoing protocol descriptor.
- PRIORITY - Static variable in class com.devexperts.qd.qtp.socket.ConnectOrder
-
- process(DataIterator, DataVisitor) - Static method in class com.devexperts.qd.DataBuffer
-
- process(RecordCursor, T, C) - Method in class com.devexperts.qd.kit.ArrayListAttachmentStrategy
-
- process(RecordSource) - Method in class com.devexperts.qd.ng.RecordBuffer
-
Adds all records from the specified source to this buffer.
- process(RecordSource, SubscriptionFilter) - Method in class com.devexperts.qd.ng.RecordBuffer
-
Adds all records that match a given filter from the specified source to this buffer.
- process(RecordSource) - Method in interface com.devexperts.qd.ng.RecordConsumer
-
Processes all records from specified record source.
- process(RecordSource) - Method in interface com.devexperts.qd.QDDistributor
-
Processes all data from specified record source.
- process(SubscriptionIterator, SubscriptionVisitor) - Static method in class com.devexperts.qd.SubscriptionBuffer
-
- process(RecordSource) - Method in class com.devexperts.qd.util.DataProcessor
-
Deprecated.
- process(RecordSource) - Method in class com.devexperts.qd.util.RecordProcessor
-
Method for processing incoming records.
- processAddedSubscription(RecordSource) - Method in class com.devexperts.qd.util.SubscriptionProcessor
-
Method for processing incoming added subscription from QD.
- processData(DataIterator) - Method in class com.devexperts.qd.DataBuffer
-
Deprecated.
- processData(DataIterator) - Method in interface com.devexperts.qd.DataConsumer
-
- processData(DataIterator, SubscriptionFilter) - Method in class com.devexperts.qd.ng.RecordBuffer
-
Processes data from specified iterator and adds to this record buffer all records that are
accepted by the specified filter.
- processData(DataIterator) - Method in class com.devexperts.qd.ng.RecordBuffer
-
Processes data from specified iterator and adds to this record buffer all records.
- processData(DataIterator) - Method in interface com.devexperts.qd.QDDistributor
-
- processData(DataIterator, MessageType) - Method in class com.devexperts.qd.qtp.DistributorAdapter
-
- processData(DataIterator, MessageType) - Method in class com.devexperts.qd.qtp.MessageConsumerAdapter
-
- processData(DataIterator, MessageType) - Method in interface com.devexperts.qd.qtp.RawDataConsumer
-
- processData(RecordSource) - Method in class com.devexperts.qd.util.DataProcessor
-
Deprecated.
Method for processing incoming data from QD.
- processData(DataIterator, DataVisitor) - Static method in class com.devexperts.qd.util.LegacyIteratorUtils
-
Processes data from specified iterator via specified visitor.
- processDescribeProtocol(ProtocolDescriptor, boolean) - Method in class com.devexperts.qd.qtp.AgentAdapter
-
- processDescribeProtocol(ProtocolDescriptor, boolean) - Method in class com.devexperts.qd.qtp.DistributorAdapter
-
- processDescribeProtocol(ProtocolDescriptor, boolean) - Method in class com.devexperts.qd.qtp.MessageAdapter
-
Process incoming protocol descriptor.
- processDescribeProtocol(ProtocolDescriptor) - Method in class com.devexperts.qd.qtp.MessageAdapter
-
- processDescribeProtocol(ProtocolDescriptor, boolean) - Method in interface com.devexperts.qd.qtp.MessageConsumer
-
Processes incoming protocol descriptor and returns true
if this message
consumer understands the protocol that remote peer intends to use.
- processDescribeProtocol(ProtocolDescriptor, boolean) - Method in class com.devexperts.qd.qtp.MessageConsumerAdapter
-
- processEach(RecordCursor, C) - Method in class com.devexperts.qd.kit.ArrayListAttachmentStrategy
-
- processHeartbeat(HeartbeatPayload) - Method in interface com.devexperts.qd.qtp.MessageConsumer
-
- processHeartbeat(HeartbeatPayload) - Method in class com.devexperts.qd.qtp.MessageConsumerAdapter
-
- processHistoryAddSubscription(SubscriptionIterator) - Method in interface com.devexperts.qd.qtp.MessageConsumer
-
- processHistoryAddSubscription(SubscriptionIterator) - Method in class com.devexperts.qd.qtp.MessageConsumerAdapter
-
This implementation calls processSubscription(iterator, MessageType.HISTORY_ADD_SUBSCRIPTION)
.
- processHistoryData(DataIterator) - Method in interface com.devexperts.qd.qtp.MessageConsumer
-
- processHistoryData(DataIterator) - Method in class com.devexperts.qd.qtp.MessageConsumerAdapter
-
This implementation calls processData(iterator, MessageType.HISTORY_DATA)
.
- processHistoryRemoveSubscription(SubscriptionIterator) - Method in interface com.devexperts.qd.qtp.MessageConsumer
-
- processHistoryRemoveSubscription(SubscriptionIterator) - Method in class com.devexperts.qd.qtp.MessageConsumerAdapter
-
This implementation calls processSubscription(iterator, MessageType.HISTORY_REMOVE_SUBSCRIPTION)
.
- processOtherMessage(int, byte[], int, int) - Method in interface com.devexperts.qd.qtp.MessageConsumer
-
- processOtherMessage(int, byte[], int, int) - Method in class com.devexperts.qd.qtp.MessageConsumerAdapter
-
This implementation calls handleUnknownMessage(message_type)
.
- processOtherMessage(int, BufferedInput, int) - Method in class com.devexperts.qd.qtp.MessageConsumerAdapter
-
- processPending(MessageConsumer) - Method in class com.devexperts.qd.qtp.AbstractQTPParser
-
Processes pending message from buffers (if any) and resets them to null
.
- processRecordSource(RecordSource, MessageType) - Method in class com.devexperts.qd.qtp.MessageConsumerAdapter
-
- processRemovedSubscription(RecordSource) - Method in class com.devexperts.qd.util.SubscriptionProcessor
-
Method for processing incoming removed subscription from QD.
- processStreamAddSubscription(SubscriptionIterator) - Method in interface com.devexperts.qd.qtp.MessageConsumer
-
- processStreamAddSubscription(SubscriptionIterator) - Method in class com.devexperts.qd.qtp.MessageConsumerAdapter
-
This implementation calls processSubscription(iterator, MessageType.STREAM_ADD_SUBSCRIPTION)
.
- processStreamData(DataIterator) - Method in interface com.devexperts.qd.qtp.MessageConsumer
-
- processStreamData(DataIterator) - Method in class com.devexperts.qd.qtp.MessageConsumerAdapter
-
This implementation calls processData(iterator, MessageType.STREAM_DATA)
.
- processStreamRemoveSubscription(SubscriptionIterator) - Method in interface com.devexperts.qd.qtp.MessageConsumer
-
- processStreamRemoveSubscription(SubscriptionIterator) - Method in class com.devexperts.qd.qtp.MessageConsumerAdapter
-
This implementation calls processSubscription(iterator, MessageType.STREAM_REMOVE_SUBSCRIPTION)
.
- processSubscription(SubscriptionIterator, SubscriptionFilter) - Method in class com.devexperts.qd.ng.RecordBuffer
-
Processes subscription from specified iterator and adds to this record buffer all records that are
accepted by the specified filter.
- processSubscription(SubscriptionIterator) - Method in class com.devexperts.qd.ng.RecordBuffer
-
Processes subscription from specified iterator and adds to this record buffer all records.
- processSubscription(SubscriptionIterator, MessageType) - Method in class com.devexperts.qd.qtp.AgentAdapter
-
- processSubscription(RecordSource, QDContract, boolean) - Method in class com.devexperts.qd.qtp.AgentChannels
-
Processes subscription.
- processSubscription(SubscriptionIterator, MessageType) - Method in class com.devexperts.qd.qtp.MessageConsumerAdapter
-
- processSubscription(SubscriptionIterator) - Method in class com.devexperts.qd.SubscriptionBuffer
-
Deprecated.
- processSubscription(SubscriptionIterator) - Method in interface com.devexperts.qd.SubscriptionConsumer
-
- processSubscription(SubscriptionIterator, SubscriptionVisitor) - Static method in class com.devexperts.qd.util.LegacyIteratorUtils
-
Processes subscription from specified iterator via specified visitor.
- processTickerAddSubscription(SubscriptionIterator) - Method in interface com.devexperts.qd.qtp.MessageConsumer
-
- processTickerAddSubscription(SubscriptionIterator) - Method in class com.devexperts.qd.qtp.MessageConsumerAdapter
-
This implementation calls processSubscription(iterator, MessageType.TICKER_ADD_SUBSCRIPTION)
.
- processTickerData(DataIterator) - Method in interface com.devexperts.qd.qtp.MessageConsumer
-
- processTickerData(DataIterator) - Method in class com.devexperts.qd.qtp.MessageConsumerAdapter
-
This implementation calls processData(iterator, MessageType.TICKER_DATA)
.
- processTickerRemoveSubscription(SubscriptionIterator) - Method in interface com.devexperts.qd.qtp.MessageConsumer
-
- processTickerRemoveSubscription(SubscriptionIterator) - Method in class com.devexperts.qd.qtp.MessageConsumerAdapter
-
This implementation calls processSubscription(iterator, MessageType.TICKER_REMOVE_SUBSCRIPTION)
.
- processTimeProgressReport(long) - Method in class com.devexperts.qd.qtp.MessageConsumerAdapter
-
- produceUpdatedFilter() - Method in class com.devexperts.qd.kit.NotFilter
-
- produceUpdatedFilter() - Method in class com.devexperts.qd.kit.SymbolSetFilter
-
- produceUpdatedFilter() - Method in class com.devexperts.qd.QDFilter
-
This method is called under
synchronized(this)
when
fireFilterUpdated
is called with
null
argument to synchronously produce updated instance of this filter.
- props - Variable in class com.devexperts.qd.qtp.QDEndpoint.Builder
-
- ProtocolDescriptor - Class in com.devexperts.qd.qtp
-
- ProtocolOption - Enum in com.devexperts.qd.qtp
-
Optional features of QTP protocol.
- ProtocolOption.Set - Class in com.devexperts.qd.qtp
-
Set of QTP protocol options.
- proxyHost - Variable in class com.devexperts.qd.qtp.socket.ClientSocketConnector
-
- proxyPort - Variable in class com.devexperts.qd.qtp.socket.ClientSocketConnector
-
- put(int, String, T) - Method in class com.devexperts.qd.util.SymbolObjectMap
-
- put(int, char[], int, int, T) - Method in class com.devexperts.qd.util.SymbolObjectMap
-
- putNonDefaultPropertyName(String, String) - Method in class com.devexperts.qd.ng.RecordMapping
-
Defines non-default property name in descendant classes constructors.
- RANDOM - Static variable in class com.devexperts.qd.qtp.socket.ConnectOrder
-
- RANGE_DELIMITER - Static variable in class com.devexperts.qd.kit.RangeFilter
-
Range filter delimiter string.
- RANGE_DELIMITER_CHAR - Static variable in class com.devexperts.qd.kit.RangeFilter
-
Range filter delimiter character.
- RANGE_FILTER_PREFIX - Static variable in class com.devexperts.qd.kit.RangeFilter
-
Range filter prefix.
- RANGE_STRIPER_PREFIX - Static variable in class com.devexperts.qd.kit.RangeStriper
-
- rangeCodes - Variable in class com.devexperts.qd.kit.RangeStriper
-
- RangeFilter - Class in com.devexperts.qd.kit
-
Range symbol filter with specification range-<A>-<B>-
, where A and B are range boundaries
using dictionary [a-zA-Z0-9], accepts symbols that are greater or equal than A and less than B skipping
non-dictionary prefix.
- RangeFilter(DataScheme, String, String) - Constructor for class com.devexperts.qd.kit.RangeFilter
-
- RangeFilter(DataScheme, String, String, String) - Constructor for class com.devexperts.qd.kit.RangeFilter
-
- ranges - Variable in class com.devexperts.qd.kit.RangeStriper
-
- RangeStriper - Class in com.devexperts.qd.kit
-
Strategy that splits symbol universe into stripes by range boundaries.
- RangeStriper(DataScheme, String[], String) - Constructor for class com.devexperts.qd.kit.RangeStriper
-
- RangeUtil - Class in com.devexperts.qd.kit
-
- RawDataConsumer - Interface in com.devexperts.qd.qtp
-
- read(BufferedInput, RecordCursor) - Method in interface com.devexperts.qd.DataField
-
- read(BufferedInput, RecordCursor) - Method in class com.devexperts.qd.kit.AbstractDataIntField
-
- read(BufferedInput, RecordCursor) - Method in class com.devexperts.qd.kit.AbstractDataObjField
-
- read(BufferedInput, RecordCursor) - Method in class com.devexperts.qd.kit.LongField
-
- read(BufferedInput, RecordCursor) - Method in class com.devexperts.qd.kit.TimeMillisField
-
- read(BufferedInput, RecordCursor) - Method in class com.devexperts.qd.kit.VoidIntField
-
- read(BufferedInput, RecordCursor) - Method in class com.devexperts.qd.kit.WideDecimalField
-
- READ_AGGREGATION_SIZE - Static variable in class com.devexperts.qd.qtp.QTPConstants
-
Maximum number of bytes to aggregate before processing when reading data from socket.
- readAs(MessageType) - Method in class com.devexperts.qd.qtp.AbstractQTPParser
-
Overrides message type for all data and subscription messages read by this parser.
- readAvailableBytes(int) - Method in class com.devexperts.qd.util.ByteArrayDataInput
-
Deprecated.
Makes an attempt to read n
bytes of data into the buffer.
- readBoolean() - Method in class com.devexperts.qd.util.ByteArrayDataInput
-
Deprecated.
- readByte() - Method in class com.devexperts.qd.util.ByteArrayDataInput
-
Deprecated.
- readChar() - Method in class com.devexperts.qd.util.ByteArrayDataInput
-
Deprecated.
- readDataFrom(BufferedInput) - Method in class com.devexperts.qd.ng.RecordCursor
-
- readDouble() - Method in class com.devexperts.qd.util.ByteArrayDataInput
-
Deprecated.
- Reader() - Constructor for class com.devexperts.qd.SymbolCodec.Reader
-
- readEventTimeSequence - Variable in class com.devexperts.qd.qtp.AbstractQTPParser
-
- readFields(BufferedInput, RecordCursor) - Method in interface com.devexperts.qd.DataRecord
-
- readFields(BufferedInput, RecordCursor) - Method in class com.devexperts.qd.kit.DefaultRecord
-
- readFields(BufferedInput, RecordCursor, int) - Method in class com.devexperts.qd.qtp.BinaryRecordDesc
-
- readFloat() - Method in class com.devexperts.qd.util.ByteArrayDataInput
-
Deprecated.
- readFrom(DataInput) - Method in class com.devexperts.qd.ng.RecordCursor
-
- readFully(byte[]) - Method in class com.devexperts.qd.util.ByteArrayDataInput
-
Deprecated.
- readFully(byte[], int, int) - Method in class com.devexperts.qd.util.ByteArrayDataInput
-
Deprecated.
- readInt(DataInput) - Method in interface com.devexperts.qd.DataIntField
-
- readInt(BufferedInput) - Method in interface com.devexperts.qd.DataIntField
-
Reads field value from specified buffered input and returns it to the caller.
- readInt(DataInput) - Method in class com.devexperts.qd.kit.CompactCharField
-
- readInt(BufferedInput) - Method in class com.devexperts.qd.kit.CompactCharField
-
- readInt(DataInput) - Method in class com.devexperts.qd.kit.CompactIntField
-
- readInt(BufferedInput) - Method in class com.devexperts.qd.kit.CompactIntField
-
- readInt(DataInput) - Method in class com.devexperts.qd.kit.PlainIntField
-
- readInt(BufferedInput) - Method in class com.devexperts.qd.kit.PlainIntField
-
- readInt(DataInput) - Method in class com.devexperts.qd.kit.VoidIntField
-
- readInt(BufferedInput) - Method in class com.devexperts.qd.kit.VoidIntField
-
- readInt() - Method in class com.devexperts.qd.util.ByteArrayDataInput
-
Deprecated.
- readInt(DataInput) - Static method in class com.devexperts.qd.util.CompactInt
-
- readLine() - Method in class com.devexperts.qd.util.ByteArrayDataInput
-
Deprecated.
- readLong() - Method in class com.devexperts.qd.util.ByteArrayDataInput
-
Deprecated.
- readLong(DataInput) - Static method in class com.devexperts.qd.util.CompactInt
-
- readObj(DataInput) - Method in interface com.devexperts.qd.DataObjField
-
- readObj(BufferedInput) - Method in interface com.devexperts.qd.DataObjField
-
Reads field value from specified data input and returns it to the caller.
- readObj(DataInput) - Method in class com.devexperts.qd.kit.ByteArrayField
-
- readObj(BufferedInput) - Method in class com.devexperts.qd.kit.ByteArrayField
-
- readObj(DataInput) - Method in class com.devexperts.qd.kit.MarshalledObjField
-
- readObj(BufferedInput) - Method in class com.devexperts.qd.kit.MarshalledObjField
-
- readObj(DataInput) - Method in class com.devexperts.qd.kit.PlainObjField
-
Deprecated.
- readObj(BufferedInput) - Method in class com.devexperts.qd.kit.PlainObjField
-
Deprecated.
- readObj(DataInput) - Method in class com.devexperts.qd.kit.StringField
-
- readObj(BufferedInput) - Method in class com.devexperts.qd.kit.StringField
-
- readObj(DataInput) - Method in class com.devexperts.qd.kit.VoidObjField
-
- readObj(BufferedInput) - Method in class com.devexperts.qd.kit.VoidObjField
-
- readRecord(BufferedInput, RecordBuffer, int, String, int) - Method in class com.devexperts.qd.qtp.BinaryRecordDesc
-
Reads record from the specified input and adds it to the specified cursor.
- readRecordId(BufferedInput) - Method in class com.devexperts.qd.qtp.BinaryQTPParser
-
- readShort() - Method in class com.devexperts.qd.util.ByteArrayDataInput
-
Deprecated.
- readString(DataInput) - Static method in class com.devexperts.qd.util.CompactChar
-
- readSubscriptionTime(BufferedInput) - Method in class com.devexperts.qd.qtp.BinaryQTPParser
-
- readSymbol(BufferedInput) - Method in class com.devexperts.qd.qtp.BinaryQTPParser
-
- readSymbol(BufferedInput, SymbolCodec.Resolver) - Method in class com.devexperts.qd.SymbolCodec.Reader
-
- readTime(BufferedInput) - Method in class com.devexperts.qd.qtp.BinaryRecordDesc
-
- readUnsignedByte() - Method in class com.devexperts.qd.util.ByteArrayDataInput
-
Deprecated.
- readUnsignedShort() - Method in class com.devexperts.qd.util.ByteArrayDataInput
-
Deprecated.
- readUTF() - Method in class com.devexperts.qd.util.ByteArrayDataInput
-
Deprecated.
- receiveSymbol(int, String) - Method in interface com.devexperts.qd.SymbolReceiver
-
Remembers specified cipher and symbol.
- reconfigure() - Method in class com.devexperts.qd.qtp.AbstractMessageConnector
-
- reconfigure() - Method in class com.devexperts.qd.qtp.socket.ServerSocketConnector
-
- reconnect() - Method in class com.devexperts.qd.qtp.AbstractMessageConnector
-
- reconnect() - Method in interface com.devexperts.qd.qtp.MessageConnectorMBean
-
Reconnects connector.
- RECONNECT_DELAY - Static variable in class com.devexperts.qd.qtp.QTPConstants
-
Default reconnection delay in QTP.
- reconnectActiveConnectors() - Method in class com.devexperts.qd.qtp.QDEndpoint
-
- ReconnectHelper - Class in com.devexperts.qd.qtp
-
Helper class to manage reconnection delay for message connectors.
- ReconnectHelper(long) - Constructor for class com.devexperts.qd.qtp.ReconnectHelper
-
- record - Variable in class com.devexperts.qd.qtp.BinaryRecordDesc
-
- RecordBuffer - Class in com.devexperts.qd.ng
-
Buffers int and obj values of data records.
- RecordBuffer() - Constructor for class com.devexperts.qd.ng.RecordBuffer
-
Creates new
RecordBuffer
with a default mode of
DATA
.
- RecordBuffer(RecordMode) - Constructor for class com.devexperts.qd.ng.RecordBuffer
-
Creates new RecordBuffer
with a specified mode.
- RecordConsumer - Interface in com.devexperts.qd.ng
-
- RecordCursor - Class in com.devexperts.qd.ng
-
Provides high-performance safe read (and optional write) access to one record
(one row on information in DB terms) directly from any int[]
and Object[]
data arrays that might constitute a part of a larger data structure.
- RecordCursor() - Constructor for class com.devexperts.qd.ng.RecordCursor
-
- RecordCursor.Owner - Class in com.devexperts.qd.ng
-
RecordCursor
contains an implicit reference to
RecordCursor
.
- RecordFilter - Interface in com.devexperts.qd.ng
-
- RecordListener - Interface in com.devexperts.qd.ng
-
Receives notifications about data availability in the corresponding record providers.
- RecordMapping - Class in com.devexperts.qd.ng
-
Base class for record mappings.
- RecordMapping(DataRecord) - Constructor for class com.devexperts.qd.ng.RecordMapping
-
Creates record mapping for a specified record.
- RecordMappingFactory - Interface in com.devexperts.qd.ng
-
- RecordMode - Class in com.devexperts.qd.ng
-
- RecordOnlyFilter - Class in com.devexperts.qd.kit
-
Subscription filter that filters only based on the record name.
- RecordOnlyFilter(DataScheme) - Constructor for class com.devexperts.qd.kit.RecordOnlyFilter
-
- RecordProcessor - Class in com.devexperts.qd.util
-
This class is base class for listening for records availability and rescheduling their processing using
Executor
.
- RecordProcessor(Executor) - Constructor for class com.devexperts.qd.util.RecordProcessor
-
Constructs new record processor for the specified executor.
- RecordProvider - Interface in com.devexperts.qd.ng
-
An object that can notify about new records and let retrieve them.
- records - Variable in class com.devexperts.qd.kit.DefaultScheme
-
- recordsAvailable(RecordProvider) - Method in interface com.devexperts.qd.ng.RecordListener
-
Notifies this listener that records are available in the specified record provider.
- recordsAvailable() - Method in interface com.devexperts.qd.qtp.AgentChannels.Owner
-
Notifies the owner when records are available.
- RecordSink - Interface in com.devexperts.qd.ng
-
An object to which data records can be appended.
- RecordSource - Class in com.devexperts.qd.ng
-
- registerMonitoringTask(Runnable) - Method in class com.devexperts.qd.qtp.QDEndpoint
-
This method registers monitoring task that is invoked periodically when "qds-monitoring" module
is in classpath.
- reinitConfiguration(AuthSession) - Method in class com.devexperts.qd.qtp.AgentAdapter
-
- reinitConfiguration(AuthSession) - Method in class com.devexperts.qd.qtp.MessageAdapter
-
Updates the adapter configuration.
- reinitConfiguration() - Method in class com.devexperts.qd.qtp.MessageAdapterConnectionFactory
-
- release() - Method in class com.devexperts.qd.ng.RecordBuffer
-
Releases this RecordBuffer
to a thread-local pool.
- release(SubscriptionIterator, RecordSource) - Static method in class com.devexperts.qd.util.LegacyAdapter
-
- remapRecord(int, BinaryRecordDesc) - Method in class com.devexperts.qd.qtp.BinaryQTPParser
-
- remoteEndpointId - Variable in class com.devexperts.qd.qtp.MessageAdapter
-
- remove(RecordSource) - Method in interface com.devexperts.qd.QDCollector
-
Removes the corresponding records from the underlying storage.
- remove(int, String) - Method in class com.devexperts.qd.util.SymbolObjectMap
-
- remove(int, char[], int, int) - Method in class com.devexperts.qd.util.SymbolObjectMap
-
- remove(int, String) - Method in class com.devexperts.qd.util.SymbolSet
-
- remove(int, char[], int, int) - Method in class com.devexperts.qd.util.SymbolSet
-
- removeAt(long) - Method in class com.devexperts.qd.ng.RecordBuffer
-
Removes record at the specified position.
- removeBytes(int) - Method in class com.devexperts.qd.qtp.ByteArrayComposer
-
Deprecated.
Removes specified number of bytes from the start of the buffer.
- removeBytes(int, int) - Method in class com.devexperts.qd.qtp.ByteArrayComposer
-
Deprecated.
Removes specified number of bytes from a specified part of the buffer
from offset off
with a length of len
.
- removeBytes(int) - Method in class com.devexperts.qd.qtp.ByteArrayParser
-
Deprecated.
Removes specified number of bytes from the start of the buffer.
- removeChild(QDStats, int) - Method in class com.devexperts.qd.stats.QDStats
-
- removeConnectors(Collection<MessageConnector>) - Method in class com.devexperts.qd.qtp.QDEndpoint
-
- removeConnectorsImpl(Collection<MessageConnector>) - Method in class com.devexperts.qd.qtp.QDEndpoint
-
- removeMessageConnectionListener(MessageConnectorListener) - Method in class com.devexperts.qd.qtp.QDEndpoint
-
- removeMessageConnectorListener(MessageConnectorListener) - Method in class com.devexperts.qd.qtp.AbstractMessageConnector
-
- removeMessageConnectorListener(MessageConnectorListener) - Method in interface com.devexperts.qd.qtp.MessageConnector
-
Removes the specified
listener
from this message connector.
- removeMessageConnectorListener(Collection<? extends MessageConnector>, MessageConnectorListener) - Static method in class com.devexperts.qd.qtp.MessageConnectors
-
- removePlugin(QDEndpoint.Plugin) - Method in class com.devexperts.qd.qtp.QDEndpoint
-
- removeRange(long, long) - Method in class com.devexperts.qd.ng.RecordBuffer
-
Removes records from the specified fromPosition inclusive and toPosition exclusive.
- removeSubscription(SubscriptionIterator) - Method in interface com.devexperts.qd.QDAgent
-
- removeSubscription(RecordSource) - Method in interface com.devexperts.qd.QDAgent
-
Removes specified subscription from this agent's data interest.
- removeSubscriptionPart(RecordSource, int) - Method in interface com.devexperts.qd.QDAgent
-
Removes part of specified subscription from this agent's data interest.
- removeUpdateListener(QDFilter.UpdateListener) - Method in class com.devexperts.qd.QDFilter
-
Removes listener for
dynamic
filter.
- removeUpdateListener(QDFilter.UpdateListener) - Method in class com.devexperts.qd.QDFilter.Updated
-
- replaceFieldIfNeeded(RecordCursor) - Method in class com.devexperts.qd.qtp.AbstractQTPParser
-
- replaceRecordAt(long, DataRecord) - Method in class com.devexperts.qd.ng.RecordBuffer
-
Replaces record at the specified position.
- replaceSymbolAt(long, int, String) - Method in class com.devexperts.qd.ng.RecordBuffer
-
Replaces symbol at the specified position.
- reportIgnoredMessage(String, MessageType) - Method in class com.devexperts.qd.qtp.MessageAdapter
-
- REPRESENTATION_MASK - Static variable in class com.devexperts.qd.SerialFieldType.Bits
-
Masks representation bits of type id (encodes details of representation of the field value in the code).
- reset() - Method in class com.devexperts.qd.ng.RecordCursor.Owner
-
Resets cursor to its initial state.
- reset() - Method in class com.devexperts.qd.ng.RecordCursor
-
- reset() - Method in class com.devexperts.qd.qtp.ReconnectHelper
-
- reset(ProtocolOption.Set) - Method in class com.devexperts.qd.SymbolCodec.Reader
-
Resets reader at the beginning of packet.
- reset(ProtocolOption.Set) - Method in class com.devexperts.qd.SymbolCodec.Writer
-
Resets writer at the beginning of packet.
- resetBuffer() - Method in class com.devexperts.qd.qtp.ByteArrayParser
-
Deprecated.
- resetEndpointStats() - Method in class com.devexperts.qd.qtp.AbstractMessageConnector
-
- resetEndpointStats() - Method in interface com.devexperts.qd.qtp.MessageConnectorMBean
-
Resets endpoint statistics
- resetSession() - Method in class com.devexperts.qd.qtp.AbstractQTPComposer
-
Resets session state for composer with describe records mode.
- resetSession() - Method in class com.devexperts.qd.qtp.AbstractQTPParser
-
- resetSession() - Method in class com.devexperts.qd.qtp.BinaryQTPParser
-
Resets session state for this parser.
- restart() - Method in class com.devexperts.qd.qtp.AbstractMessageConnector
-
- restart() - Method in interface com.devexperts.qd.qtp.MessageConnectorMBean
-
Restarts connector (connection is immediately dropped and established again).
- restartActiveConnectors() - Method in class com.devexperts.qd.qtp.QDEndpoint
-
- restartImpl(boolean) - Method in class com.devexperts.qd.qtp.AbstractMessageConnector
-
Restart logic implementation; If fullStop is false
, connection context
(like last chosen address for multi-host connections) may be preserved.
- restartImpl(boolean) - Method in class com.devexperts.qd.qtp.socket.ClientSocketConnector
-
- restoreGracefully(String) - Method in class com.devexperts.qd.qtp.socket.ClientSocketConnector
-
- restoreGracefully(String) - Method in interface com.devexperts.qd.qtp.socket.ClientSocketConnectorMBean
-
Restore connection graceful with delay in TimePeriod format
- restoreNow() - Method in class com.devexperts.qd.qtp.socket.ClientSocketConnector
-
- restoreNow() - Method in interface com.devexperts.qd.qtp.socket.ClientSocketConnectorMBean
-
- resyncOnCorrupted(BufferedInput) - Method in class com.devexperts.qd.qtp.BinaryQTPParser
-
Extension point to resynchronize broken/partial input stream on corrupted message.
- resyncOnParse(BufferedInput) - Method in class com.devexperts.qd.qtp.BinaryQTPParser
-
Extension point to resynchronize broken/partial input stream before each message.
- retainAll(SymbolSet) - Method in class com.devexperts.qd.util.SymbolSet
-
- retainAll(QDFilter) - Method in class com.devexperts.qd.util.SymbolSet
-
- retrieve(RecordSink) - Method in class com.devexperts.qd.ng.AbstractRecordProvider
-
Retrieves accumulated records into the specified record sink
while the sink
has capacity
.
- retrieve(RecordSink) - Method in class com.devexperts.qd.ng.RecordBuffer
-
- retrieve(RecordSink) - Method in interface com.devexperts.qd.ng.RecordProvider
-
Retrieves accumulated records into the specified record sink
while the sink
has capacity
.
- retrieve(RecordSink) - Method in class com.devexperts.qd.ng.RecordSource
-
- retrieve(RecordSink) - Method in class com.devexperts.qd.util.CompositeRecordProvider
-
- retrieveCompleteEndpointStats() - Method in class com.devexperts.qd.qtp.AbstractMessageConnector
-
- retrieveCompleteEndpointStats() - Method in interface com.devexperts.qd.qtp.MessageConnectorMBean
-
Retrieves endpoint statistics for this message connector since its creation
- retrieveCompleteEndpointStats() - Method in class com.devexperts.qd.qtp.socket.ClientSocketConnector
-
- retrieveCompleteEndpointStats() - Method in class com.devexperts.qd.qtp.socket.ServerSocketConnector
-
- retrieveData(DataVisitor) - Method in class com.devexperts.qd.DataBuffer
-
Deprecated.
- retrieveData(DataVisitor) - Method in interface com.devexperts.qd.DataProvider
-
Retrieves accumulated data into specified data visitor.
- retrieveData(DataVisitor) - Method in class com.devexperts.qd.ng.AbstractRecordProvider
-
- retrieveData(DataVisitor) - Method in class com.devexperts.qd.ng.RecordBuffer
-
- retrieveData(DataVisitor) - Method in interface com.devexperts.qd.ng.RecordProvider
-
- retrieveData(DataProvider, QDContract) - Method in interface com.devexperts.qd.qtp.AgentChannels.Owner
-
Retrieves accumulated data from data provider.
- retrieveData() - Method in class com.devexperts.qd.qtp.AgentChannels
-
Retrieves accumulated messages using the provided RetrieveFromProvider function.
- retrieveDataMessages(MessageVisitor) - Method in class com.devexperts.qd.qtp.AgentAdapter
-
- retrieveDescribeProtocolMessage(MessageVisitor, long) - Method in class com.devexperts.qd.qtp.MessageAdapter
-
- retrieveMask() - Method in class com.devexperts.qd.qtp.MessageAdapter
-
- retrieveMessageAdapterFactory(ApplicationConnectionFactory) - Static method in class com.devexperts.qd.qtp.MessageConnectors
-
- retrieveMessages(MessageVisitor) - Method in class com.devexperts.qd.qtp.AgentAdapter
-
- retrieveMessages(MessageVisitor) - Method in class com.devexperts.qd.qtp.DistributorAdapter
-
- retrieveMessages(MessageVisitor) - Method in class com.devexperts.qd.qtp.MessageAdapter
-
- retrieveMessages(MessageVisitor) - Method in interface com.devexperts.qd.qtp.MessageProvider
-
Retrieves accumulated message into specified message visitor.
- retrieveSubscription(SubscriptionVisitor) - Method in class com.devexperts.qd.ng.AbstractRecordProvider
-
- retrieveSubscription(SubscriptionVisitor) - Method in class com.devexperts.qd.ng.RecordBuffer
-
- retrieveSubscription(SubscriptionVisitor) - Method in interface com.devexperts.qd.ng.RecordProvider
-
- retrieveSubscription(SubscriptionVisitor) - Method in class com.devexperts.qd.SubscriptionBuffer
-
Deprecated.
- retrieveSubscription(SubscriptionVisitor) - Method in interface com.devexperts.qd.SubscriptionProvider
-
Retrieves accumulated subscription into specified subscription visitor.
- rewind() - Method in class com.devexperts.qd.ng.RecordBuffer
-
Sets
position
of this buffer to the beginning, so that added record can be retrieved again.
- RID_ADDED - Static variable in class com.devexperts.qd.stats.QDStats.SValue
-
- RID_CHANGED - Static variable in class com.devexperts.qd.stats.QDStats.SValue
-
- RID_FILTERED - Static variable in class com.devexperts.qd.stats.QDStats.SValue
-
- RID_REMOVED - Static variable in class com.devexperts.qd.stats.QDStats.SValue
-
- RID_SIZE - Static variable in class com.devexperts.qd.stats.QDStats.SValue
-
- rightChars - Variable in class com.devexperts.qd.kit.RangeFilter
-
- rightCode - Variable in class com.devexperts.qd.kit.RangeFilter
-
- RMI_PROPERTY - Static variable in class com.devexperts.qd.qtp.ProtocolDescriptor
-
- run() - Method in class com.devexperts.qd.qtp.QTPWorkerThread
-
- runDaily(Runnable, LocalTime) - Method in class com.devexperts.qd.util.DxTimer
-
Run periodic Runnable
task that will start every day in LocalTime
- runOnce(Runnable, long) - Method in class com.devexperts.qd.util.DxTimer
-
Run one-time delayed Runnable
task
- RuntimeQTPException - Exception in com.devexperts.qd.qtp
-
- RuntimeQTPException(Throwable) - Constructor for exception com.devexperts.qd.qtp.RuntimeQTPException
-
Creates new QTP runtime IO exception with a specified cause.
- scheme - Variable in class com.devexperts.qd.kit.RangeStriper
-
- scheme - Variable in class com.devexperts.qd.qtp.AbstractQTPComposer
-
- scheme - Variable in class com.devexperts.qd.qtp.AbstractQTPParser
-
- scheme - Variable in class com.devexperts.qd.qtp.MessageAdapter.AbstractFactory
-
- scheme - Variable in class com.devexperts.qd.qtp.QDEndpoint.Builder
-
- SEQUENCE - Static variable in class com.devexperts.qd.SerialFieldType
-
- SequenceField - Class in com.devexperts.qd.kit
-
- SequenceField(int, String) - Constructor for class com.devexperts.qd.kit.SequenceField
-
- SequenceField(int, String, SerialFieldType) - Constructor for class com.devexperts.qd.kit.SequenceField
-
- SER_BYTE - Static variable in class com.devexperts.qd.qtp.BinaryRecordDesc
-
- SER_BYTE_ARRAY - Static variable in class com.devexperts.qd.qtp.BinaryRecordDesc
-
- SER_COMPACT_INT - Static variable in class com.devexperts.qd.qtp.BinaryRecordDesc
-
- SER_INT - Static variable in class com.devexperts.qd.qtp.BinaryRecordDesc
-
- SER_MARSHALLED - Static variable in class com.devexperts.qd.qtp.BinaryRecordDesc
-
- SER_MASK - Static variable in class com.devexperts.qd.qtp.BinaryRecordDesc
-
- SER_OTHER - Static variable in class com.devexperts.qd.qtp.BinaryRecordDesc
-
- SER_PLAIN_OBJECT - Static variable in class com.devexperts.qd.qtp.BinaryRecordDesc
-
- SER_SHIFT - Static variable in class com.devexperts.qd.qtp.BinaryRecordDesc
-
- SER_SHORT - Static variable in class com.devexperts.qd.qtp.BinaryRecordDesc
-
- SER_UTF_CHAR - Static variable in class com.devexperts.qd.qtp.BinaryRecordDesc
-
- SER_UTF_CHAR_ARRAY_STRING - Static variable in class com.devexperts.qd.qtp.BinaryRecordDesc
-
- SER_UTF_STRING - Static variable in class com.devexperts.qd.qtp.BinaryRecordDesc
-
- SERIAL_OBJECT - Static variable in class com.devexperts.qd.SerialFieldType
-
- SERIAL_TYPE_MASK - Static variable in class com.devexperts.qd.SerialFieldType.Bits
-
This mask should be used to check if two types are equal in terms of their serial representations.
- SerialFieldType - Class in com.devexperts.qd
-
Describes serial type of
data fields
that are transferred via QTP.
- SerialFieldType.Bits - Class in com.devexperts.qd
-
Bit patterns for serial field type ids.
- SERVER_SOCKET_CONNECTOR - Static variable in class com.devexperts.qd.stats.QDStats.SType
-
- ServerConnectorMBean - Interface in com.devexperts.qd.qtp
-
- ServerSocketConnector - Class in com.devexperts.qd.qtp.socket
-
The ServerSocketConnector
handles standard server socket using blocking API.
- ServerSocketConnector(MessageAdapter.Factory, int) - Constructor for class com.devexperts.qd.qtp.socket.ServerSocketConnector
-
- ServerSocketConnector(ApplicationConnectionFactory, int) - Constructor for class com.devexperts.qd.qtp.socket.ServerSocketConnector
-
Creates new server socket connector.
- ServerSocketConnectorMBean - Interface in com.devexperts.qd.qtp.socket
-
- ServerSocketTestHelper - Class in com.devexperts.qd.qtp.socket
-
- SERVICES_PROPERTY - Static variable in class com.devexperts.qd.qtp.ProtocolDescriptor
-
- set(int) - Method in enum com.devexperts.qd.ng.EventFlag
-
- setAddress(String) - Method in class com.devexperts.qd.qtp.socket.ClientSocketConnector
-
- setAddress(String) - Method in interface com.devexperts.qd.qtp.socket.ClientSocketConnectorMBean
-
- setAggregationPeriod(TimePeriod) - Method in class com.devexperts.qd.qtp.AgentAdapter.Factory
-
- setAggregationPeriod(long) - Method in class com.devexperts.qd.qtp.ChannelShaper
-
Sets aggregation period for this channel data.
- setArrays(int[], Object[]) - Method in class com.devexperts.qd.ng.RecordCursor.Owner
-
Changes pointer to data integer and object array.
- setAs(RecordCursor) - Method in class com.devexperts.qd.ng.RecordCursor.Owner
-
Configures the
cursor
to be exactly as the other cursor.
- setAs(DataRecord, int, String, int[], int, Object[], int, boolean) - Method in class com.devexperts.qd.ng.RecordCursor
-
- setAsDouble(RecordCursor, int, double) - Method in class com.devexperts.qd.ng.RecordMapping
-
- setAsInt(RecordCursor, int, int) - Method in class com.devexperts.qd.ng.RecordMapping
-
- setAsLong(RecordCursor, int, long) - Method in class com.devexperts.qd.ng.RecordMapping
-
- setAsTimeMillis(RecordCursor, int, long) - Method in class com.devexperts.qd.ng.RecordMapping
-
- setAsTimeSeconds(RecordCursor, int, int) - Method in class com.devexperts.qd.ng.RecordMapping
-
- setAsTinyDecimal(RecordCursor, int, int) - Method in class com.devexperts.qd.ng.RecordMapping
-
- setAsWideDecimal(RecordCursor, int, long) - Method in class com.devexperts.qd.ng.RecordMapping
-
- setAttachment(Object) - Method in class com.devexperts.qd.ng.RecordCursor.Owner
-
Changes object attachment that is associated with the current cursor
when attachment is not part of the record mode.
- setAttachment(Object) - Method in class com.devexperts.qd.ng.RecordCursor
-
Changes object attachment that is associated with the current record.
- setAuth(String) - Method in class com.devexperts.qd.qtp.MessageAdapterConnectionFactory
-
- setAuthRealm(QDAuthRealm) - Method in class com.devexperts.qd.qtp.MessageAdapter
-
- setBindAddr(String) - Method in class com.devexperts.qd.qtp.AbstractServerConnector
-
- setBindAddr(String) - Method in interface com.devexperts.qd.qtp.MessageConnector.Bindable
-
Deprecated.
- setBindAddr(String) - Method in interface com.devexperts.qd.qtp.ServerConnectorMBean
-
- setBuffer(byte[]) - Method in class com.devexperts.qd.util.ByteArrayBuffer
-
Deprecated.
Sets specified byte array to be used for buffering.
- setBufferOverflowStrategy(int, boolean, boolean) - Method in interface com.devexperts.qd.QDAgent
-
- setBufferOverflowStrategy(QDAgent.BufferOverflowStrategy) - Method in interface com.devexperts.qd.QDAgent
-
Sets new strategy for handling of stream and history buffer overflow events.
- setCapacityLimit(int) - Method in class com.devexperts.qd.ng.RecordBuffer
-
Sets the capacity limit in the number of records for this record buffer.
- setCapacityLimited(boolean) - Method in class com.devexperts.qd.ng.RecordBuffer
-
Changes capacity-limited flag of this record buffer.
- setChannels(String) - Method in class com.devexperts.qd.qtp.AgentAdapter.Factory
-
- setCloseListener(MessageAdapter.CloseListener) - Method in class com.devexperts.qd.qtp.MessageAdapter
-
- setCollector(QDCollector) - Method in class com.devexperts.qd.qtp.ChannelShaper
-
Sets collector for the channel.
- setConfiguration(ConfigurationKey<T>, T) - Method in class com.devexperts.qd.qtp.MessageAdapterConnectionFactory
-
- setConnectionVariables(TypedMap) - Method in class com.devexperts.qd.qtp.MessageAdapter
-
Sets per-connection variables for this message adapter.
- setConnectOrder(ConnectOrder) - Method in class com.devexperts.qd.qtp.socket.ClientSocketConnector
-
- setConnectOrder(ConnectOrder) - Method in interface com.devexperts.qd.qtp.socket.ClientSocketConnectorMBean
-
- setConnectorInitializer(QDEndpoint.ConnectorInitializer) - Method in class com.devexperts.qd.qtp.QDEndpoint
-
- setDataFilter(RecordFilter) - Method in class com.devexperts.qd.qtp.ChannelShaper
-
Sets data filter for the channel.
- setDataListener(DataListener) - Method in class com.devexperts.qd.DataBuffer
-
Deprecated.
- setDataListener(DataListener) - Method in interface com.devexperts.qd.DataProvider
-
Sets new data listener to receive notifications about data.
- setDataListener(DataListener) - Method in class com.devexperts.qd.ng.AbstractRecordProvider
-
- setDataListener(DataListener) - Method in class com.devexperts.qd.ng.RecordBuffer
-
- setDataListener(DataListener) - Method in interface com.devexperts.qd.ng.RecordProvider
-
- setDefaultProperties(Object, Class<?>, String) - Static method in class com.devexperts.qd.util.QDConfig
-
- setDeltaMark(int) - Method in class com.devexperts.qd.qtp.HeartbeatPayload
-
- setEnableWildcards(boolean) - Method in interface com.devexperts.qd.QDStream
-
Sets "wildcards enabled" mode (disabled by default).
- setEndpoint(Class<?>, T) - Method in class com.devexperts.qd.qtp.MessageAdapter.ConfigurableFactory
-
- setEndpointId(EndpointId) - Method in class com.devexperts.qd.qtp.ProtocolDescriptor
-
- setErrorHandler(QDErrorHandler) - Method in interface com.devexperts.qd.QDCollector
-
Sets errors handler for all errors that are happening during notification of agents
and distributors.
- setEventFlags(int) - Method in class com.devexperts.qd.ng.RecordCursor.Owner
-
Changes event flags that are associated with the current cursor
when event flags are not part of the record mode.
- setEventFlags(int) - Method in class com.devexperts.qd.ng.RecordCursor
-
Changes event flags that are associated with the current record.
- setEventSequence(int) - Method in class com.devexperts.qd.ng.RecordCursor
-
Changes event sequence that is associated with the current record.
- setEventTimeSeconds(int) - Method in class com.devexperts.qd.ng.RecordCursor
-
Changes event time seconds value that is associated with the current record.
- setEventTimeSequence(long) - Method in class com.devexperts.qd.ng.RecordCursor
-
Changes event time sequence that is associated with the current record.
- setEventTimeSequence(long) - Method in class com.devexperts.qd.qtp.AbstractQTPParser
-
- setEventTimeSequenceIfNeeded(RecordCursor) - Method in class com.devexperts.qd.qtp.AbstractQTPParser
-
- setFactory(ApplicationConnectionFactory) - Method in class com.devexperts.qd.qtp.AbstractMessageConnector
-
- setFactory(ApplicationConnectionFactory) - Method in interface com.devexperts.qd.qtp.MessageConnector
-
Changes ApplicationConnectionFactory
that is used by this message connector.
- setFieldReplacer(String) - Method in class com.devexperts.qd.qtp.AbstractMessageConnector
-
- setFieldReplacer(String) - Method in class com.devexperts.qd.qtp.DistributorAdapter.Factory
-
Set Field Replacers configuration for input data.
- setFieldReplacer(String) - Method in interface com.devexperts.qd.qtp.MessageConnectorMBean
-
Sets input field replacers.
- SetFieldReplacerFactory - Class in com.devexperts.qd.qtp.fieldreplacer
-
This factory creates an implementation of
FieldReplacer
that provides an ability
to set value of one record's field to value of another field of same type.
- SetFieldReplacerFactory() - Constructor for class com.devexperts.qd.qtp.fieldreplacer.SetFieldReplacerFactory
-
- setFieldReplacers(FieldReplacersCache) - Method in class com.devexperts.qd.qtp.AbstractQTPParser
-
- setFilter(String) - Method in class com.devexperts.qd.qtp.MessageAdapter.AbstractFactory
-
Sets additional filter for this factory.
- setHeartbeatPeriod(TimePeriod) - Method in class com.devexperts.qd.qtp.MessageAdapterConnectionFactory
-
- setHeartbeatTimeout(TimePeriod) - Method in class com.devexperts.qd.qtp.MessageAdapterConnectionFactory
-
- setHost(String) - Method in class com.devexperts.qd.qtp.socket.ClientSocketConnector
-
Deprecated.
- setId(int) - Method in class com.devexperts.qd.qtp.MessageDescriptor
-
- setInitialHeartbeatPeriod(TimePeriod) - Method in class com.devexperts.qd.qtp.MessageAdapterConnectionFactory
-
- setInput(BufferedInput) - Method in class com.devexperts.qd.qtp.AbstractQTPParser
-
Changes input to parse messages from.
- setInput(BufferedInput) - Method in class com.devexperts.qd.qtp.ByteArrayParser
-
Deprecated.
Changes input to parse messages from.
- setInput(BufferedInput) - Method in class com.devexperts.qd.qtp.InputStreamParser
-
Changes input to parse messages from.
- setInt(int, int) - Method in class com.devexperts.qd.ng.RecordCursor
-
- setInt(RecordCursor, int, int) - Method in class com.devexperts.qd.ng.RecordMapping
-
- setIntValue(RecordCursor, int, int, BufferedInput) - Method in class com.devexperts.qd.qtp.BinaryRecordDesc
-
- setLagMark(int) - Method in class com.devexperts.qd.qtp.HeartbeatPayload
-
- setLimit(long) - Method in class com.devexperts.qd.ng.RecordBuffer
-
Sets new buffer limit and discards everything that written after that point.
- setLimit(int) - Method in class com.devexperts.qd.qtp.ByteArrayParser
-
Deprecated.
Sets new value for number of bytes in the buffer.
- setLimit(int) - Method in class com.devexperts.qd.util.ByteArrayBuffer
-
Deprecated.
Sets this buffer's limit.
- setLinkTo(long) - Method in class com.devexperts.qd.ng.RecordCursor
-
Changes link to the previous record in list that is associated with the current record.
- setLocalPort(int) - Method in class com.devexperts.qd.qtp.AbstractServerConnector
-
- setLocalPort(int) - Method in interface com.devexperts.qd.qtp.ServerConnectorMBean
-
- setLogin(String) - Method in class com.devexperts.qd.qtp.MessageAdapterConnectionFactory
-
- setLoginHandler(QDLoginHandler) - Method in class com.devexperts.qd.qtp.MessageAdapter
-
- setLong(int, long) - Method in class com.devexperts.qd.ng.RecordCursor
-
- setLong(RecordCursor, int, long) - Method in class com.devexperts.qd.ng.RecordMapping
-
- setLongValue(RecordCursor, int, long, BufferedInput) - Method in class com.devexperts.qd.qtp.BinaryRecordDesc
-
- setMaxBufferSize(int) - Method in interface com.devexperts.qd.QDAgent
-
Sets max buffers size for stream and history agents.
- setMaxConnections(int) - Method in class com.devexperts.qd.qtp.AbstractServerConnector
-
- setMaxConnections(int) - Method in interface com.devexperts.qd.qtp.ServerConnectorMBean
-
- setMessageListener(MessageListener) - Method in class com.devexperts.qd.qtp.MessageAdapter
-
Note: this method SHOULD be called before calling .start()
- it does not give immediate notification regarding the pending messages
- setMessageListener(MessageListener) - Method in interface com.devexperts.qd.qtp.MessageProvider
-
Sets new message listener to receive notifications about messages.
- setMessageType(MessageType) - Method in class com.devexperts.qd.qtp.MessageDescriptor
-
- setMessageType(MessageType) - Method in class com.devexperts.qd.qtp.OutputStreamComposer
-
Sets message type for subsequent data or subscription.
- setMixedSubscription(boolean) - Method in class com.devexperts.qd.qtp.AbstractQTPParser
-
- setMode(RecordMode) - Method in class com.devexperts.qd.ng.RecordBuffer
-
Changes current mode of this record buffer.
- setName(String) - Method in class com.devexperts.qd.kit.SymbolSetFilter
-
- setName(String) - Method in class com.devexperts.qd.QDFilter
-
Sets a custom string representation for this filter.
- setName(String) - Method in class com.devexperts.qd.qtp.AbstractMessageConnector
-
Overrides name of this connector for management and logging purposes.
- setName(String) - Method in interface com.devexperts.qd.qtp.MessageConnectorMBean
-
Sets connector's short name for logging and monitoring.
- setName(String) - Method in class com.devexperts.qd.qtp.MessageDescriptor
-
- setNameOrDefault(String) - Method in class com.devexperts.qd.QDFilter
-
Sets a custom string representation for this filter if its no longer than a default one.
- setObj(int, Object) - Method in class com.devexperts.qd.ng.RecordCursor
-
- setObj(RecordCursor, int, Object) - Method in class com.devexperts.qd.ng.RecordMapping
-
- setObjValue(RecordCursor, int, Object, BufferedInput) - Method in class com.devexperts.qd.qtp.BinaryRecordDesc
-
- setOffsets(int, int) - Method in class com.devexperts.qd.ng.RecordCursor.Owner
-
Changes offsets in data integer and data object arrays.
- setOptSet(ProtocolOption.Set) - Method in class com.devexperts.qd.qtp.AbstractQTPComposer
-
- setOutput(BufferedOutput) - Method in class com.devexperts.qd.qtp.AbstractQTPComposer
-
Changes output for the composed messages.
- setOutput(BufferedOutput) - Method in class com.devexperts.qd.qtp.ByteArrayComposer
-
Deprecated.
Changes output for the composed messages.
- setOutput(BufferedOutput) - Method in class com.devexperts.qd.qtp.OutputStreamComposer
-
Changes output for the composed messages.
- setParentReferences(DataScheme) - Static method in class com.devexperts.qd.kit.DefaultScheme
-
- setPassword(String) - Method in class com.devexperts.qd.qtp.AbstractMessageConnector
-
- setPassword(String) - Method in class com.devexperts.qd.qtp.MessageAdapterConnectionFactory
-
- setPassword(String) - Method in interface com.devexperts.qd.qtp.MessageConnectorMBean
-
Sets password for authorization.
- setPort(int) - Method in class com.devexperts.qd.qtp.socket.ClientSocketConnector
-
Deprecated.
- setPosition(long) - Method in class com.devexperts.qd.ng.RecordBuffer
-
Changes position of the current record.
- setPosition(long) - Method in class com.devexperts.qd.ng.RecordSource
-
Changes position of the current record.
- setPosition(int) - Method in class com.devexperts.qd.util.ByteArrayBuffer
-
Deprecated.
Sets this buffer's position.
- setProperties(Object, List<String>) - Static method in class com.devexperts.qd.util.QDConfig
-
- setProperties(Object, Class<?>, List<String>) - Static method in class com.devexperts.qd.util.QDConfig
-
- setProperty(String, String) - Method in class com.devexperts.qd.qtp.MessageDescriptor
-
- setProperty(String, String) - Method in class com.devexperts.qd.qtp.ProtocolDescriptor
-
- setProxyHost(String) - Method in class com.devexperts.qd.qtp.socket.ClientSocketConnector
-
- setProxyHost(String) - Method in interface com.devexperts.qd.qtp.socket.ClientSocketConnectorMBean
-
- setProxyPort(int) - Method in class com.devexperts.qd.qtp.socket.ClientSocketConnector
-
- setProxyPort(int) - Method in interface com.devexperts.qd.qtp.socket.ClientSocketConnectorMBean
-
- setReadEventTimeSequence(boolean) - Method in class com.devexperts.qd.qtp.AbstractQTPParser
-
- setReadOnly(boolean) - Method in class com.devexperts.qd.ng.RecordCursor.Owner
-
Changes read only mode of the corresponding cursor.
- setReconnectDelay(long) - Method in class com.devexperts.qd.qtp.AbstractMessageConnector
-
- setReconnectDelay(long) - Method in interface com.devexperts.qd.qtp.MessageConnectorMBean
-
Sets reconnection delay.
- setReconnectDelay(long) - Method in class com.devexperts.qd.qtp.ReconnectHelper
-
Change the delay period for the helper.
- setRecord(DataRecord) - Method in class com.devexperts.qd.kit.AbstractDataField
-
Sets reference to parent data record.
- setRecord(DataRecord) - Method in class com.devexperts.qd.ng.RecordCursor.Owner
-
Changes record and sets a default mode of
DATA
.
- setRecord(DataRecord, RecordMode) - Method in class com.devexperts.qd.ng.RecordCursor.Owner
-
Changes record and sets a specified mode.
- setRecordListener(RecordListener) - Method in class com.devexperts.qd.ng.AbstractRecordProvider
-
Sets new record listener to receive notifications about available records.
- setRecordListener(RecordListener) - Method in class com.devexperts.qd.ng.RecordBuffer
-
- setRecordListener(RecordListener) - Method in interface com.devexperts.qd.ng.RecordProvider
-
Sets new record listener to receive notifications about available records.
- setRecordListener(RecordListener) - Method in class com.devexperts.qd.util.CompositeRecordProvider
-
- setRemoteOptSet(MessageAdapter, ProtocolOption.Set) - Method in class com.devexperts.qd.qtp.AbstractConnectionHandler
-
- setRemoteOptSet(ProtocolOption.Set) - Method in class com.devexperts.qd.qtp.MessageAdapter
-
- setRestoreTime(String) - Method in class com.devexperts.qd.qtp.socket.ClientSocketConnector
-
- setRestoreTime(String) - Method in interface com.devexperts.qd.qtp.socket.ClientSocketConnectorMBean
-
- setScheme(DefaultScheme) - Method in class com.devexperts.qd.kit.DefaultRecord
-
Sets reference to parent data scheme.
- setScheme(DataScheme) - Method in interface com.devexperts.qd.spi.DataSchemeService
-
Sets data scheme for this service.
- setScheme(DataScheme) - Method in class com.devexperts.qd.spi.QDFilterFactory
-
Sets data scheme for this filter factory.
- setScheme(DataScheme) - Method in class com.devexperts.qd.spi.SymbolStriperFactory
-
Sets data scheme for this filter factory.
- setShortName(String) - Method in class com.devexperts.qd.QDFilter
-
Sets a short-name string representation for this filter.
- setStats(QDStats) - Method in class com.devexperts.qd.qtp.AbstractMessageConnector
-
- setStats(QDStats) - Method in class com.devexperts.qd.qtp.AbstractQTPComposer
-
Changes stats to gather composer statistics.
- setStats(QDStats) - Method in class com.devexperts.qd.qtp.AbstractQTPParser
-
Changes stats to gather parser statistics.
- setStats(QDStats) - Method in interface com.devexperts.qd.qtp.MessageConnector
-
Changes
QDStats
associated with this message connector.
- setStats(QDStats) - Method in class com.devexperts.qd.qtp.socket.ClientSocketConnector
-
Sets stats for this connector.
- setStats(QDStats) - Method in class com.devexperts.qd.qtp.socket.ServerSocketConnector
-
Sets stats for this connector.
- setStoreEverything(boolean) - Method in interface com.devexperts.qd.QDCollector
-
Sets "store everything" mode (disabled by default).
- setStoreEverythingFilter(SubscriptionFilter) - Method in interface com.devexperts.qd.QDCollector
-
Sets filter that is used for "store everything" mode.
- setStreamOverflowStrategy(int, boolean, boolean) - Method in interface com.devexperts.qd.QDAgent
-
- setString(RecordCursor, String) - Method in interface com.devexperts.qd.DataField
-
- setString(RecordCursor, String) - Method in class com.devexperts.qd.kit.AbstractDataIntField
-
- setString(RecordCursor, String) - Method in class com.devexperts.qd.kit.AbstractDataObjField
-
- setString(RecordCursor, String) - Method in class com.devexperts.qd.kit.LongField
-
- setString(RecordCursor, String) - Method in class com.devexperts.qd.kit.TimeMillisField
-
- setString(RecordCursor, String) - Method in class com.devexperts.qd.kit.VoidIntField
-
- setString(RecordCursor, String) - Method in class com.devexperts.qd.kit.WideDecimalField
-
- setStripe(String) - Method in class com.devexperts.qd.qtp.socket.ClientSocketConnector
-
- setStripe(String) - Method in interface com.devexperts.qd.qtp.socket.ClientSocketConnectorMBean
-
- setStripeFilter(String) - Method in class com.devexperts.qd.qtp.MessageAdapter.AbstractFactory
-
Sets stripe (represented as QDFilter) for this factory.
- setSubscription(SubscriptionIterator) - Method in interface com.devexperts.qd.QDAgent
-
- setSubscription(RecordSource) - Method in interface com.devexperts.qd.QDAgent
-
Sets specified subscription to be this agent's data interest.
- setSubscriptionExecutor(Executor) - Method in class com.devexperts.qd.qtp.AgentAdapter.Factory
-
- setSubscriptionFilter(SubscriptionFilter) - Method in class com.devexperts.qd.qtp.ChannelShaper
-
- setSubscriptionFilter(QDFilter) - Method in class com.devexperts.qd.qtp.ChannelShaper
-
Sets subscription filter for the channel.
- setSubscriptionFilter(QDFilter) - Method in class com.devexperts.qd.qtp.DynamicChannelShaper
-
- setSubscriptionKeepAlive(TimePeriod) - Method in class com.devexperts.qd.qtp.AgentAdapter.Factory
-
- setSubscriptionListener(SubscriptionListener) - Method in class com.devexperts.qd.ng.AbstractRecordProvider
-
- setSubscriptionListener(SubscriptionListener) - Method in class com.devexperts.qd.ng.RecordBuffer
-
- setSubscriptionListener(SubscriptionListener) - Method in interface com.devexperts.qd.ng.RecordProvider
-
- setSubscriptionListener(SubscriptionListener) - Method in class com.devexperts.qd.SubscriptionBuffer
-
Deprecated.
- setSubscriptionListener(SubscriptionListener) - Method in interface com.devexperts.qd.SubscriptionProvider
-
Sets new subscription listener to receive notifications about subscription.
- setSubscriptionPart(RecordSource, int) - Method in interface com.devexperts.qd.QDAgent
-
Sets part of specified subscription to be this agent's data interest.
- setSubscriptionThreads(int) - Method in class com.devexperts.qd.qtp.AgentAdapter.Factory
-
- setSymbol(int, String) - Method in class com.devexperts.qd.ng.RecordCursor.Owner
-
Changes cipher and symbol.
- setThreadPriority(int) - Method in class com.devexperts.qd.qtp.AbstractMessageConnector
-
- setThreadPriority(int) - Method in interface com.devexperts.qd.qtp.MessageConnectorMBean
-
Sets thread priority for all threads created by this connector.
- setThreadPriority(Collection<? extends MessageConnector>, int) - Static method in class com.devexperts.qd.qtp.MessageConnectors
-
- setTime(long) - Method in class com.devexperts.qd.ng.RecordCursor
-
Changes time of this record that is a long value composed of the value of the first two integer fields.
- setTimeMark(int) - Method in class com.devexperts.qd.ng.RecordCursor.Owner
-
Changes time mark that is associated with the current cursor
when time mark is not part of the record mode.
- setTimeMark(int) - Method in class com.devexperts.qd.ng.RecordCursor
-
Changes time mark that is associated with the current record.
- setTimeMark(int) - Method in class com.devexperts.qd.qtp.HeartbeatPayload
-
- setTimeMillis(long) - Method in class com.devexperts.qd.qtp.HeartbeatPayload
-
- setTls(boolean) - Method in class com.devexperts.qd.qtp.socket.ClientSocketConnector
-
Deprecated.
- setTls(boolean) - Method in class com.devexperts.qd.qtp.socket.ServerSocketConnector
-
- setTrustManager(TrustManager) - Method in class com.devexperts.qd.qtp.socket.ClientSocketConnector
-
Deprecated.
- setUser(String) - Method in class com.devexperts.qd.qtp.AbstractMessageConnector
-
- setUser(String) - Method in class com.devexperts.qd.qtp.MessageAdapterConnectionFactory
-
- setUser(String) - Method in interface com.devexperts.qd.qtp.MessageConnectorMBean
-
Sets connector's user name for authorization.
- setVersion(String) - Static method in class com.devexperts.qd.QDFactory
-
Overwrites string description of this QDS version for testing purposes only.
- setWeight(int) - Method in class com.devexperts.qd.qtp.ChannelShaper
-
Sets relative weight of this channel data within the adapter for shaping.
- setWriteEventTimeSequence(boolean) - Method in class com.devexperts.qd.qtp.AbstractQTPComposer
-
- setWriteHeartbeat(boolean) - Method in class com.devexperts.qd.qtp.AbstractQTPComposer
-
- shift - Variable in class com.devexperts.qd.kit.HashFilter
-
- SHORT - Static variable in class com.devexperts.qd.SerialFieldType
-
- SHORT_STRING - Static variable in class com.devexperts.qd.SerialFieldType
-
- ShortString - Class in com.devexperts.qd.util
-
Auxiliary class for converting short (up to 8 characters) strings into primitive long values and backwards.
- ShortStringField - Class in com.devexperts.qd.kit
-
The ShortStringField
represents a short (up to 4 characters) string
in a single integer with compact serialized form.
- ShortStringField(int, String) - Constructor for class com.devexperts.qd.kit.ShortStringField
-
- ShortStringField(int, String, SerialFieldType) - Constructor for class com.devexperts.qd.kit.ShortStringField
-
- shortValue() - Method in class com.devexperts.qd.util.Decimal
-
- showVersion() - Static method in class com.devexperts.qd.QDFactory
-
Shows QDS version in the log (at most once).
- SHUFFLE - Static variable in class com.devexperts.qd.qtp.socket.ConnectOrder
-
- sign(int) - Static method in class com.devexperts.qd.util.Decimal
-
- signalNoMoreToProcess() - Method in class com.devexperts.qd.util.RecordProcessor
-
- signalNoMoreToProcess() - Method in class com.devexperts.qd.util.SubscriptionProcessor
-
- signedDeltaMark(int) - Static method in class com.devexperts.qd.util.TimeMarkUtil
-
- size() - Method in class com.devexperts.qd.DataBuffer
-
Deprecated.
Returns number of records in this data buffer.
- size() - Method in class com.devexperts.qd.ng.RecordBuffer
-
Returns the number of records that were added to this RecordBuffer.
- size() - Method in class com.devexperts.qd.qtp.ProtocolOption.Set
-
- size() - Method in class com.devexperts.qd.SubscriptionBuffer
-
Deprecated.
Returns number of records in this subscription buffer.
- size() - Method in class com.devexperts.qd.SymbolList
-
- size() - Method in class com.devexperts.qd.util.SymbolObjectMap
-
- size() - Method in class com.devexperts.qd.util.SymbolSet.ListSet
-
- size() - Method in class com.devexperts.qd.util.SymbolSet
-
- skipBytes(int) - Method in class com.devexperts.qd.util.ByteArrayDataInput
-
Deprecated.
- skipConnectorOnStart(MessageConnector) - Method in class com.devexperts.qd.qtp.QDEndpoint.Plugin
-
- skipPrefix(long) - Static method in class com.devexperts.qd.kit.RangeUtil
-
Returns encoded string value stripped from unused prefix.
- skipPrefix(String) - Static method in class com.devexperts.qd.kit.RangeUtil
-
Returns index in the string of the symbol stripped from unused prefix.
- skipPrefix(String, int) - Static method in class com.devexperts.qd.kit.RangeUtil
-
Returns index in the string of the symbol stripped from unused prefix.
- skipPrefix(char[], int, int) - Static method in class com.devexperts.qd.kit.RangeUtil
-
- skipRecord(DataRecord, DataIterator) - Static method in class com.devexperts.qd.util.DataIterators
-
- sleepBeforeConnection() - Method in class com.devexperts.qd.qtp.ReconnectHelper
-
- SOCKET_KEY - Static variable in class com.devexperts.qd.qtp.MessageConnectors
-
- SocketAddress - Class in com.devexperts.qd.qtp.socket
-
- socketAddresses - Variable in class com.devexperts.qd.qtp.socket.ClientSocketConnector
-
- SocketMessageAdapterFactory - Interface in com.devexperts.qd.qtp.socket
-
This interface should be implemented by MessageAdapter.Factory
in order to
run any custom authorization/authentication protocol with remote host.
- SocketUtil - Class in com.devexperts.qd.qtp.socket
-
- SpecificSubscriptionFilter - Annotation Type in com.devexperts.qd
-
Describes project-specific subscription filter.
- splitParenthesisedStringAt(String, char) - Static method in class com.devexperts.qd.util.QDConfig
-
Finds first occurrence of atChar
while honoring quotation by '('..')' and '['...']' pairs.
- splitParenthesisSeparatedString(String) - Static method in class com.devexperts.qd.util.QDConfig
-
Splits a parenthesis-separated collection like '('<item>')'('<item>')...('<item>')
.
- StableSubscriptionFilter - Interface in com.devexperts.qd
-
Stable subscription filter has a fixed logic (it cannot depend on any external resources or state)
and it is reconstructible from string by
SubscriptionFilterFactory
.
- start() - Method in class com.devexperts.qd.qtp.AbstractMessageConnector
-
- start() - Method in class com.devexperts.qd.qtp.AbstractServerConnector
-
- start() - Method in class com.devexperts.qd.qtp.MessageAdapter
-
Starts this adapter.
- start(MasterMessageAdapter) - Method in class com.devexperts.qd.qtp.MessageAdapter
-
Same as start, but when slave is true it starts in slave mode.
- start() - Method in interface com.devexperts.qd.qtp.MessageConnectorMBean
-
Starts connector (connection is immediately established).
- start() - Method in class com.devexperts.qd.qtp.socket.ClientSocketConnector
-
- startAcceptorInternal() - Method in class com.devexperts.qd.qtp.AbstractServerConnector
-
- startAcceptorInternal() - Method in class com.devexperts.qd.qtp.socket.ServerSocketConnector
-
- startConnectors() - Method in class com.devexperts.qd.qtp.QDEndpoint
-
- startImpl(boolean) - Method in class com.devexperts.qd.qtp.AbstractServerConnector
-
- startImpl(MasterMessageAdapter) - Method in class com.devexperts.qd.qtp.DistributorAdapter
-
- startImpl(MasterMessageAdapter) - Method in class com.devexperts.qd.qtp.MessageAdapter
-
- startImpl(boolean) - Method in class com.devexperts.qd.qtp.socket.ServerSocketConnector
-
- startMessageConnectors(Collection<? extends MessageConnector>) - Static method in class com.devexperts.qd.qtp.MessageConnectors
-
- startProcessing(DataProvider) - Method in class com.devexperts.qd.util.DataProcessor
-
Deprecated.
- startProcessing(RecordProvider) - Method in class com.devexperts.qd.util.RecordProcessor
-
- startProcessing(QDDistributor) - Method in class com.devexperts.qd.util.SubscriptionProcessor
-
- startProcessing(RecordProvider, RecordProvider) - Method in class com.devexperts.qd.util.SubscriptionProcessor
-
Starts subscription processing for the specified added and removed
RecordProvider
instances.
- stateChanged(MessageConnector) - Method in interface com.devexperts.qd.qtp.MessageConnectorListener
-
Invoked when connections are established or broken in the MessageConnector.
- stats - Variable in class com.devexperts.qd.qtp.AbstractQTPComposer
-
- stats - Variable in class com.devexperts.qd.qtp.AbstractQTPParser
-
Where to collect stats to.
- STATS_KEY - Static variable in class com.devexperts.qd.qtp.MessageConnectors
-
- StatsLock() - Constructor for class com.devexperts.qd.stats.QDStats.StatsLock
-
- stop() - Method in class com.devexperts.qd.qtp.AbstractMessageConnector
-
- stop() - Method in interface com.devexperts.qd.qtp.MessageConnectorMBean
-
Stops connector (connection is immediately dropped).
- stopAcceptor() - Method in class com.devexperts.qd.qtp.AbstractServerConnector
-
- stopAcceptor() - Method in interface com.devexperts.qd.qtp.ServerConnectorMBean
-
Stop accepting new connections
- stopAcceptorInternal() - Method in class com.devexperts.qd.qtp.AbstractServerConnector
-
- stopAcceptorInternal() - Method in class com.devexperts.qd.qtp.socket.ServerSocketConnector
-
- stopAndWait() - Method in class com.devexperts.qd.qtp.AbstractMessageConnector
-
- stopAndWait() - Method in interface com.devexperts.qd.qtp.MessageConnector
-
Stops connector and waits while all its threads are terminated.
- stopConnectors() - Method in class com.devexperts.qd.qtp.QDEndpoint
-
- stopConnectorsAndWait() - Method in class com.devexperts.qd.qtp.QDEndpoint
-
- stopConnectorsAndWaitUninterruptibly() - Method in class com.devexperts.qd.qtp.QDEndpoint
-
- stopGracefully(String) - Method in class com.devexperts.qd.qtp.AbstractServerConnector
-
Stopping server socket acceptor and smooth closing of all connections during a specified period
- stopGracefully(String) - Method in interface com.devexperts.qd.qtp.ServerConnectorMBean
-
Stop connector gracefully within period of time
- stopImpl() - Method in class com.devexperts.qd.qtp.AbstractMessageConnector
-
- stopImpl() - Method in class com.devexperts.qd.qtp.socket.ClientSocketConnector
-
- stopImpl() - Method in class com.devexperts.qd.qtp.socket.ServerSocketConnector
-
- stopMessageConnectors(Collection<? extends MessageConnector>) - Static method in class com.devexperts.qd.qtp.MessageConnectors
-
- stopProcessing() - Method in class com.devexperts.qd.util.RecordProcessor
-
Stops processing.
- stopProcessing() - Method in class com.devexperts.qd.util.SubscriptionProcessor
-
Stop subscription processing.
- STORAGE_DATA - Static variable in class com.devexperts.qd.stats.QDStats.SType
-
- storeEverything - Variable in class com.devexperts.qd.qtp.QDEndpoint.Builder
-
- stream - Variable in class com.devexperts.qd.qtp.MessageAdapter.AbstractFactory
-
- STREAM - Static variable in class com.devexperts.qd.stats.QDStats.SType
-
- streamBuilder() - Method in class com.devexperts.qd.QDFactory
-
- STRING - Static variable in class com.devexperts.qd.SerialFieldType
-
- StringField - Class in com.devexperts.qd.kit
-
The StringField
represents a character sequence field
with CESU-8 serialized form.
- StringField(int, String) - Constructor for class com.devexperts.qd.kit.StringField
-
- StringField(int, String, boolean) - Constructor for class com.devexperts.qd.kit.StringField
-
- StringUtil - Class in com.devexperts.qd.util
-
- stripe - Variable in class com.devexperts.qd.qtp.MessageAdapter.AbstractFactory
-
- STRIPE_FILTER_CONFIGURATION_KEY - Static variable in class com.devexperts.qd.qtp.MessageConnectors
-
- STRIPE_PROPERTY - Static variable in class com.devexperts.qd.qtp.ProtocolDescriptor
-
- stripeConfig - Variable in class com.devexperts.qd.qtp.socket.ClientSocketConnector
-
- stripeCount - Variable in class com.devexperts.qd.kit.RangeStriper
-
- striper - Variable in class com.devexperts.qd.qtp.QDEndpoint.Builder
-
- striper - Variable in class com.devexperts.qd.qtp.socket.ClientSocketConnector
-
- SType(String) - Constructor for class com.devexperts.qd.stats.QDStats.SType
-
- SType(String, int, QDStats.SType...) - Constructor for class com.devexperts.qd.stats.QDStats.SType
-
Creates type with the given name
and flag
and which is equivalent to the listed types.
- subscribe(QDEndpoint) - Method in class com.devexperts.qd.qtp.QDEndpoint.Builder
-
- SUBSCRIPTION - Static variable in class com.devexperts.qd.ng.RecordMode
-
Store no integer and no object field values.
- subscriptionAvailable(SubscriptionProvider) - Method in class com.devexperts.qd.qtp.DistributorAdapter
-
- subscriptionAvailable(SubscriptionProvider) - Method in interface com.devexperts.qd.SubscriptionListener
-
Notifies this listener that subscription is available in the specified
subscription provider.
- SubscriptionBuffer - Class in com.devexperts.qd
-
- SubscriptionBuffer() - Constructor for class com.devexperts.qd.SubscriptionBuffer
-
Deprecated.
- subscriptionChanged(SubscriptionProvider, MessageType) - Method in class com.devexperts.qd.qtp.DistributorAdapter
-
- SubscriptionConsumer - Interface in com.devexperts.qd
-
- SubscriptionContainer - Interface in com.devexperts.qd
-
The SubscriptionContainer
represents data structure that keeps subscription
in map-like fashion.
- SubscriptionFilter - Interface in com.devexperts.qd
-
The SubscriptionFilter
is used to block unwanted subscription.
- SubscriptionFilterFactory - Interface in com.devexperts.qd.qtp
-
- SubscriptionFilterFactory - Interface in com.devexperts.qd
-
- SubscriptionIterator - Interface in com.devexperts.qd
-
The SubscriptionIterator
provides serial access to subscription.
- SubscriptionListener - Interface in com.devexperts.qd
-
The SubscriptionListener
is used to receive notifications about
subscription availability in the corresponding subscription providers.
- SubscriptionProcessor - Class in com.devexperts.qd.util
-
This class is base class for listening QD for subscription availability and rescheduling its processing using
Executor
.
- SubscriptionProcessor(Executor, QDContract) - Constructor for class com.devexperts.qd.util.SubscriptionProcessor
-
Constructs new subscription processor for the specified executor.
- SubscriptionProvider - Interface in com.devexperts.qd
-
The SubscriptionProvider
allows retrieval of accumulated subscription.
- SubscriptionVisitor - Interface in com.devexperts.qd
-
The SubscriptionVisitor
provides serial access to subscription.
- subtract(int, int) - Static method in class com.devexperts.qd.util.Decimal
-
Subtracts the second specified decimal from the first specified decimal and returns result as decimal.
- SUPPORTED_SET - Static variable in enum com.devexperts.qd.qtp.ProtocolOption
-
All supported protocol options.
- supportedConfiguration() - Method in class com.devexperts.qd.qtp.MessageAdapterConnectionFactory
-
- supportsFlag(int) - Method in class com.devexperts.qd.stats.QDStats.SValue
-
- supportsMixedSubscription() - Method in class com.devexperts.qd.qtp.AgentAdapter
-
- supportsMixedSubscription() - Method in class com.devexperts.qd.qtp.MessageAdapter
-
- supportsProperty(String) - Method in class com.devexperts.qd.qtp.QDEndpoint.Builder
-
Returns true if the corresponding property key is supported.
- symbol - Variable in class com.devexperts.qd.SymbolCodec.Reader
-
- SYMBOL_FIELD_NAME - Static variable in class com.devexperts.qd.qtp.BuiltinFields
-
- SYMBOL_PATTERN - Static variable in class com.devexperts.qd.kit.RangeFilter
-
- SymbolCodec - Interface in com.devexperts.qd
-
The SymbolCodec
defines coding and serialization of symbols.
- SymbolCodec.Reader - Class in com.devexperts.qd
-
Stateful symbol reader.
- SymbolCodec.Resolver - Interface in com.devexperts.qd
-
Symbol resolver to reuse string symbol instances.
- SymbolCodec.Writer - Class in com.devexperts.qd
-
Stateful symbol writer.
- SymbolList - Class in com.devexperts.qd
-
- SymbolList(String[], SymbolCodec) - Constructor for class com.devexperts.qd.SymbolList
-
- SymbolList(int[], String[]) - Constructor for class com.devexperts.qd.SymbolList
-
- SymbolList(int) - Constructor for class com.devexperts.qd.SymbolList
-
- SymbolList(SymbolList) - Constructor for class com.devexperts.qd.SymbolList
-
- SymbolObjectMap<T> - Class in com.devexperts.qd.util
-
Specialized hash map that maps (cipher, symbol) pair that denote symbol to an
arbitrary Object
of type T
.
- SymbolObjectMap() - Constructor for class com.devexperts.qd.util.SymbolObjectMap
-
- SymbolObjectVisitor<T> - Interface in com.devexperts.qd.util
-
- symbolReader - Variable in class com.devexperts.qd.qtp.BinaryQTPParser
-
- SymbolReceiver - Interface in com.devexperts.qd
-
The SymbolReceiver
interface provides a way to retrieve encoded
cipher-symbol pair from certain methods.
- symbols - Variable in class com.devexperts.qd.SymbolList
-
- SymbolSet - Class in com.devexperts.qd.util
-
Specialized hash set that contains (cipher, symbol) pair that denote symbol.
- SymbolSet() - Constructor for class com.devexperts.qd.util.SymbolSet
-
- SymbolSet.ListSet - Class in com.devexperts.qd.util
-
- SymbolSetFilter - Class in com.devexperts.qd.kit
-
- SymbolSetFilter(DataScheme, SymbolSet) - Constructor for class com.devexperts.qd.kit.SymbolSetFilter
-
- SymbolSetFilter(QDFilter) - Constructor for class com.devexperts.qd.kit.SymbolSetFilter
-
- SymbolStriper - Interface in com.devexperts.qd
-
Symbol striping strategy that allows to split whole symbol universe into several smaller "stripes".
- SymbolStriperFactory - Class in com.devexperts.qd.spi
-
- SymbolStriperFactory() - Constructor for class com.devexperts.qd.spi.SymbolStriperFactory
-
- SymbolStriperFactory(DataScheme) - Constructor for class com.devexperts.qd.spi.SymbolStriperFactory
-
- SymbolStriperFactoryImpl - Class in com.devexperts.qd.kit
-
- SymbolStriperFactoryImpl() - Constructor for class com.devexperts.qd.kit.SymbolStriperFactoryImpl
-
- VALID_CIPHER - Static variable in interface com.devexperts.qd.SymbolCodec
-
VALID_CIPHER defines range of valid encoded ciphers.
- validateRange(int, String) - Static method in class com.devexperts.qd.kit.RangeStriper
-
- validateRanges(String[]) - Static method in class com.devexperts.qd.kit.RangeStriper
-
- ValueFieldReplacerFactory - Class in com.devexperts.qd.qtp.fieldreplacer
-
This factory creates an implementation of
FieldReplacer
that provides an ability
to set value of one record's field to a fixed value.
- ValueFieldReplacerFactory() - Constructor for class com.devexperts.qd.qtp.fieldreplacer.ValueFieldReplacerFactory
-
- valueOf(String, DataScheme) - Static method in class com.devexperts.qd.kit.CompositeFilters
-
Parses filter specification and combines them with project-specific filters defined in the
scheme
with ',' (or) operations, '&' (and) operations, and '!' (not) operations.
- valueOf(String, String, DataScheme) - Static method in class com.devexperts.qd.kit.CompositeFilters
-
Parses filter specification and attaches project-specific name string to it.
- valueOf(String, SubscriptionFilterFactory) - Static method in class com.devexperts.qd.kit.CompositeFilters
-
Parses filter specification and combines filters defined by baseFactory
with ',' (or) operations, '&' (and) operations, and '!' (not) operations.
- valueOf(DataScheme, String) - Static method in class com.devexperts.qd.kit.HashFilter
-
Parses a given specification as hash filter for a given scheme.
- valueOf(DataScheme, String) - Static method in class com.devexperts.qd.kit.HashStriper
-
Parses a given specification as hash striper for a given scheme.
- valueOf(DataScheme, int) - Static method in class com.devexperts.qd.kit.HashStriper
-
Constructs a symbol striper for a given number of hash stripes.
- valueOf(String, DataScheme) - Static method in class com.devexperts.qd.kit.PatternFilter
-
- valueOf(String, String, DataScheme) - Static method in class com.devexperts.qd.kit.PatternFilter
-
Returns filter with a specified pattern and a project-specific name.
- valueOf(DataScheme, String) - Static method in class com.devexperts.qd.kit.RangeFilter
-
Parses a given specification as range filter for a given scheme.
- valueOf(DataScheme, String) - Static method in class com.devexperts.qd.kit.RangeStriper
-
Parses a given specification as range striper for a given scheme.
- valueOf(DataScheme, List<String>) - Static method in class com.devexperts.qd.kit.RangeStriper
-
Constructs a symbol striper for a given array of symbol ranges.
- valueOf(String, DataScheme) - Static method in class com.devexperts.qd.kit.RecordOnlyFilter
-
Parses a given specification as record-only filter for a given scheme.
- valueOf(String, DataScheme) - Static method in class com.devexperts.qd.kit.SymbolSetFilter
-
Parses a given specification as symbol set filter for a given scheme.
- valueOf(String) - Static method in enum com.devexperts.qd.ng.EventFlag
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.devexperts.qd.QDAgent.BufferOverflowStrategy
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.devexperts.qd.QDContract
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.devexperts.qd.QDFilter.Kind
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.devexperts.qd.QDFilter.SyntaxPrecedence
-
Returns the enum constant of this type with the specified name.
- valueOf(DataScheme, String) - Static method in class com.devexperts.qd.qtp.fieldreplacer.FieldReplacersCache
-
- valueOf(String) - Static method in enum com.devexperts.qd.qtp.MessageConnectorState
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.devexperts.qd.qtp.MessageType.Flag
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.devexperts.qd.qtp.MessageType
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.devexperts.qd.qtp.ProtocolOption
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in class com.devexperts.qd.qtp.socket.ConnectOrder
-
- valueOf(String) - Static method in enum com.devexperts.qd.spi.QDFilterContext
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in class com.devexperts.qd.stats.QDStats.SValue
-
- valueOf(DataScheme, String) - Static method in interface com.devexperts.qd.SymbolStriper
-
Creates
SymbolStriper
from the given specification for the given scheme,
or
null
if specification is unknown.
- valueOf(long) - Static method in class com.devexperts.qd.util.TimePeriod
-
- valueOf(String) - Static method in class com.devexperts.qd.util.TimePeriod
-
- values() - Static method in enum com.devexperts.qd.ng.EventFlag
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.devexperts.qd.QDAgent.BufferOverflowStrategy
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.devexperts.qd.QDContract
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.devexperts.qd.QDFilter.Kind
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.devexperts.qd.QDFilter.SyntaxPrecedence
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.devexperts.qd.qtp.MessageConnectorState
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.devexperts.qd.qtp.MessageType.Flag
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.devexperts.qd.qtp.MessageType
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.devexperts.qd.qtp.ProtocolOption
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.devexperts.qd.spi.QDFilterContext
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- verifyScheme(DataScheme) - Static method in class com.devexperts.qd.kit.DefaultScheme
-
- VERSION_PROPERTY - Static variable in class com.devexperts.qd.qtp.ProtocolDescriptor
-
- visitData(DataProvider, MessageType) - Method in class com.devexperts.qd.qtp.AbstractMessageVisitor
-
This method consumes available data for data message from the given data provider.
- visitData(DataProvider, MessageType) - Method in class com.devexperts.qd.qtp.AbstractQTPComposer
-
This method consumes available data for data message from the given data provider.
- visitData(DataProvider, MessageType) - Method in interface com.devexperts.qd.qtp.MessageVisitor
-
This method consumes available data for data message from the given data provider.
- visitData(DataProvider, MessageType) - Method in class com.devexperts.qd.qtp.OutputStreamComposer
-
- visitData(DataProvider, MessageType) - Method in class com.devexperts.qd.qtp.OutputStreamMessageVisitor
-
- visitDescribeProtocol(ProtocolDescriptor) - Method in class com.devexperts.qd.qtp.AbstractMessageVisitor
-
- visitDescribeProtocol(ProtocolDescriptor) - Method in class com.devexperts.qd.qtp.AbstractQTPComposer
-
- visitDescribeProtocol(ProtocolDescriptor) - Method in interface com.devexperts.qd.qtp.MessageVisitor
-
- visitEntry(int, String, T) - Method in interface com.devexperts.qd.util.SymbolObjectVisitor
-
- visitHeartbeat(HeartbeatPayload) - Method in class com.devexperts.qd.qtp.AbstractMessageVisitor
-
- visitHeartbeat(HeartbeatPayload) - Method in class com.devexperts.qd.qtp.AbstractQTPComposer
-
- visitHeartbeat(HeartbeatPayload) - Method in interface com.devexperts.qd.qtp.MessageVisitor
-
- visitHeartbeat(HeartbeatPayload) - Method in class com.devexperts.qd.qtp.OutputStreamMessageVisitor
-
- visitHistoryAddSubscription(SubscriptionProvider) - Method in class com.devexperts.qd.qtp.AbstractMessageVisitor
-
- visitHistoryAddSubscription(SubscriptionProvider) - Method in interface com.devexperts.qd.qtp.MessageVisitor
-
- visitHistoryData(DataProvider) - Method in class com.devexperts.qd.qtp.AbstractMessageVisitor
-
- visitHistoryData(DataProvider) - Method in interface com.devexperts.qd.qtp.MessageVisitor
-
- visitHistoryRemoveSubscription(SubscriptionProvider) - Method in class com.devexperts.qd.qtp.AbstractMessageVisitor
-
- visitHistoryRemoveSubscription(SubscriptionProvider) - Method in interface com.devexperts.qd.qtp.MessageVisitor
-
- visitIntField(DataIntField, int) - Method in class com.devexperts.qd.DataBuffer
-
Deprecated.
- visitIntField(DataIntField, int) - Method in interface com.devexperts.qd.DataVisitor
-
Visits next Int-field within current record.
- visitIntField(DataIntField, int) - Method in class com.devexperts.qd.ng.AbstractRecordSink
-
- visitIntField(DataIntField, int) - Method in class com.devexperts.qd.ng.RecordBuffer
-
- visitIntField(DataIntField, int) - Method in interface com.devexperts.qd.ng.RecordSink
-
- visitIntField(DataIntField, int) - Method in class com.devexperts.qd.qtp.AbstractQTPComposer
-
- visitIntField(DataIntField, int) - Method in class com.devexperts.qd.qtp.OutputStreamComposer
-
- visitObjField(DataObjField, Object) - Method in class com.devexperts.qd.DataBuffer
-
Deprecated.
- visitObjField(DataObjField, Object) - Method in interface com.devexperts.qd.DataVisitor
-
Visits next Obj-field within current record.
- visitObjField(DataObjField, Object) - Method in class com.devexperts.qd.ng.AbstractRecordSink
-
- visitObjField(DataObjField, Object) - Method in class com.devexperts.qd.ng.RecordBuffer
-
- visitObjField(DataObjField, Object) - Method in interface com.devexperts.qd.ng.RecordSink
-
- visitObjField(DataObjField, Object) - Method in class com.devexperts.qd.qtp.AbstractQTPComposer
-
- visitObjField(DataObjField, Object) - Method in class com.devexperts.qd.qtp.OutputStreamComposer
-
- visitor() - Method in class com.devexperts.qd.ng.RecordBuffer
-
- visitOtherMessage(int, byte[], int, int) - Method in class com.devexperts.qd.qtp.AbstractMessageVisitor
-
This method consumes other message type.
- visitOtherMessage(int, byte[], int, int) - Method in class com.devexperts.qd.qtp.AbstractQTPComposer
-
This method consumes other message type.
- visitOtherMessage(int, byte[], int, int) - Method in interface com.devexperts.qd.qtp.MessageVisitor
-
This method represents an extension point for QD API in order it could be
extended to handle any auxiliary messages transferred via QD.
- visitOtherMessage(int, byte[], int, int) - Method in class com.devexperts.qd.qtp.OutputStreamComposer
-
- visitOtherMessage(int, byte[], int, int) - Method in class com.devexperts.qd.qtp.OutputStreamMessageVisitor
-
- visitRecord(DataRecord, int, String) - Method in class com.devexperts.qd.DataBuffer
-
Deprecated.
- visitRecord(DataRecord, int, String) - Method in interface com.devexperts.qd.DataVisitor
-
Visits next record.
- visitRecord(DataRecord, int, String) - Method in class com.devexperts.qd.ng.AbstractRecordSink
-
- visitRecord(DataRecord, int, String, long) - Method in class com.devexperts.qd.ng.AbstractRecordSink
-
- visitRecord(DataRecord, int, String) - Method in class com.devexperts.qd.ng.RecordBuffer
-
- visitRecord(DataRecord, int, String, long) - Method in class com.devexperts.qd.ng.RecordBuffer
-
- visitRecord(DataRecord, int, String) - Method in interface com.devexperts.qd.ng.RecordSink
-
- visitRecord(DataRecord, int, String, long) - Method in interface com.devexperts.qd.ng.RecordSink
-
- visitRecord(DataRecord, int, String) - Method in class com.devexperts.qd.qtp.AbstractQTPComposer
-
- visitRecord(DataRecord, int, String, long) - Method in class com.devexperts.qd.qtp.AbstractQTPComposer
-
- visitRecord(DataRecord, int, String, long) - Method in class com.devexperts.qd.qtp.OutputStreamComposer
-
- visitRecord(DataRecord, int, String) - Method in class com.devexperts.qd.qtp.OutputStreamComposer
-
- visitRecord(DataRecord, int, String, long) - Method in class com.devexperts.qd.SubscriptionBuffer
-
Deprecated.
- visitRecord(DataRecord, int, String) - Method in class com.devexperts.qd.SubscriptionBuffer
-
Deprecated.
Visits next record using time = 0
.
- visitRecord(DataRecord, int, String, long) - Method in interface com.devexperts.qd.SubscriptionVisitor
-
Visits next record.
- visitStreamAddSubscription(SubscriptionProvider) - Method in class com.devexperts.qd.qtp.AbstractMessageVisitor
-
- visitStreamAddSubscription(SubscriptionProvider) - Method in interface com.devexperts.qd.qtp.MessageVisitor
-
- visitStreamData(DataProvider) - Method in class com.devexperts.qd.qtp.AbstractMessageVisitor
-
- visitStreamData(DataProvider) - Method in interface com.devexperts.qd.qtp.MessageVisitor
-
- visitStreamRemoveSubscription(SubscriptionProvider) - Method in class com.devexperts.qd.qtp.AbstractMessageVisitor
-
- visitStreamRemoveSubscription(SubscriptionProvider) - Method in interface com.devexperts.qd.qtp.MessageVisitor
-
- visitSubscription(SubscriptionProvider, MessageType) - Method in class com.devexperts.qd.qtp.AbstractMessageVisitor
-
This method consumes available subscription for subscription message from the given subscription provider.
- visitSubscription(SubscriptionProvider, MessageType) - Method in class com.devexperts.qd.qtp.AbstractQTPComposer
-
This method consumes available subscription for subscription message from the given subscription provider.
- visitSubscription(MessageVisitor, SubscriptionProvider, MessageType) - Method in class com.devexperts.qd.qtp.DistributorAdapter
-
- visitSubscription(SubscriptionProvider, MessageType) - Method in interface com.devexperts.qd.qtp.MessageVisitor
-
This method consumes available subscription for subscription message from the given subscription provider.
- visitSubscription(SubscriptionProvider, MessageType) - Method in class com.devexperts.qd.qtp.OutputStreamComposer
-
- visitSubscription(SubscriptionProvider, MessageType) - Method in class com.devexperts.qd.qtp.OutputStreamMessageVisitor
-
- visitTickerAddSubscription(SubscriptionProvider) - Method in class com.devexperts.qd.qtp.AbstractMessageVisitor
-
- visitTickerAddSubscription(SubscriptionProvider) - Method in interface com.devexperts.qd.qtp.MessageVisitor
-
- visitTickerData(DataProvider) - Method in class com.devexperts.qd.qtp.AbstractMessageVisitor
-
- visitTickerData(DataProvider) - Method in interface com.devexperts.qd.qtp.MessageVisitor
-
- visitTickerRemoveSubscription(SubscriptionProvider) - Method in class com.devexperts.qd.qtp.AbstractMessageVisitor
-
- visitTickerRemoveSubscription(SubscriptionProvider) - Method in interface com.devexperts.qd.qtp.MessageVisitor
-
- VOID - Static variable in class com.devexperts.qd.DataBuffer
-
- VOID - Static variable in interface com.devexperts.qd.DataConsumer
-
Deprecated.
- VOID - Static variable in interface com.devexperts.qd.DataIterator
-
- VOID - Static variable in interface com.devexperts.qd.DataListener
-
This listener immediately retrieves and discards data from provider.
- VOID - Static variable in interface com.devexperts.qd.DataVisitor
-
- VOID - Static variable in interface com.devexperts.qd.ng.RecordListener
-
This listener immediately retrieves and discards records from provider.
- VOID - Static variable in interface com.devexperts.qd.ng.RecordProvider
-
- VOID - Static variable in interface com.devexperts.qd.ng.RecordSink
-
Record sink that just ignores all records.
- VOID - Static variable in class com.devexperts.qd.ng.RecordSource
-
An empty record source.
- VOID - Static variable in class com.devexperts.qd.SerialFieldType
-
- VOID - Static variable in class com.devexperts.qd.stats.QDStats.SType
-
- VOID - Static variable in class com.devexperts.qd.stats.QDStats
-
The instance of QDStats that is always empty.
- VOID - Static variable in class com.devexperts.qd.SubscriptionBuffer
-
- VOID - Static variable in interface com.devexperts.qd.SubscriptionConsumer
-
Deprecated.
- VOID - Static variable in interface com.devexperts.qd.SubscriptionIterator
-
- VOID - Static variable in interface com.devexperts.qd.SubscriptionListener
-
This listener immediately retrieves and discards subscription from provider.
- VOID - Static variable in interface com.devexperts.qd.SubscriptionVisitor
-
- VoidIntField - Class in com.devexperts.qd.kit
-
- VoidIntField(int, String) - Constructor for class com.devexperts.qd.kit.VoidIntField
-
- VoidObjField - Class in com.devexperts.qd.kit
-
- VoidObjField(int, String) - Constructor for class com.devexperts.qd.kit.VoidObjField
-