Package | Description |
---|---|
com.devexperts.qd.ng |
This package contains next-generation interfaces for data and subscription exchange based on
RecordCursor class. |
com.devexperts.qd.qtp |
This package contains interfaces with default implementations required
to create and operate a connection using QTP.
|
Modifier and Type | Method and Description |
---|---|
static String |
EventFlag.formatEventFlags(int eventFlags,
MessageType messageType)
Converts integer event flags bit mask into an event flags set string.
|
static int |
EventFlag.getSupportedEventFlags(ProtocolOption.Set optSet,
MessageType messageType)
Returns a mask of supported event flags for a given set of protocol options and message type.
|
static int |
EventFlag.parseEventFlags(String s,
MessageType messageType)
Parses string set of event flags.
|
Modifier and Type | Field and Description |
---|---|
protected MessageType |
AbstractQTPComposer.currentMessageType |
Modifier and Type | Method and Description |
---|---|
static MessageType |
MessageType.findById(int id)
Returns message type with a given id or
null if the message type is not known. |
static MessageType |
MessageType.findByName(String name) |
static MessageType |
MessageType.forAddSubscription(QDContract contract) |
static MessageType |
MessageType.forData(QDContract contract) |
static MessageType |
MessageType.forRemoveSubscription(QDContract contract) |
MessageType |
MessageDescriptor.getMessageType() |
static MessageType |
MessageType.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static MessageType[] |
MessageType.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
EnumSet<MessageType> |
ProtocolDescriptor.getReceiveSet() |
EnumSet<MessageType> |
ProtocolDescriptor.getSendSet() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractQTPComposer.beginMessage(MessageType messageType)
Begins new message, must be followed by
AbstractQTPComposer.endMessage() . |
boolean |
ProtocolDescriptor.canReceive(MessageType message) |
boolean |
ProtocolDescriptor.canSend(MessageType message) |
protected static long |
MessageAdapter.clearMessageMask(long mask,
MessageType message) |
protected static long |
MessageAdapter.getMessageMask(MessageType message) |
MessageDescriptor |
ProtocolDescriptor.getReceive(MessageType message) |
protected RecordMode |
AbstractQTPParser.getRecordBufferMode(MessageType messageType) |
MessageDescriptor |
ProtocolDescriptor.getSend(MessageType message) |
protected static boolean |
MessageAdapter.hasMessageMask(long mask,
MessageType message) |
MessageDescriptor |
ProtocolDescriptor.newMessageDescriptor(MessageType messageType) |
static ProtocolDescriptor |
ProtocolDescriptor.newPeerProtocolDescriptorReadAs(ProtocolDescriptor original,
MessageType readAs) |
protected RecordBuffer |
AbstractQTPParser.nextRecordsMessage(MessageConsumer consumer,
MessageType messageType) |
void |
RawDataConsumer.processData(DataIterator iterator,
MessageType message) |
protected void |
MessageConsumerAdapter.processData(DataIterator iterator,
MessageType message) |
protected void |
DistributorAdapter.processData(DataIterator iterator,
MessageType message) |
void |
MessageConsumerAdapter.processRecordSource(RecordSource source,
MessageType message)
This method calls either
MessageConsumerAdapter.processData(DataIterator, MessageType) or
MessageConsumerAdapter.processSubscription(SubscriptionIterator, MessageType) depending on message. |
protected void |
MessageConsumerAdapter.processSubscription(SubscriptionIterator iterator,
MessageType message) |
protected void |
AgentAdapter.processSubscription(SubscriptionIterator iterator,
MessageType message) |
void |
AbstractQTPParser.readAs(MessageType readAs)
Overrides message type for all data and subscription messages read by this parser.
|
protected void |
MessageAdapter.reportIgnoredMessage(String reason,
MessageType message) |
void |
OutputStreamComposer.setMessageType(MessageType messageType)
Sets message type for subsequent data or subscription.
|
void |
MessageDescriptor.setMessageType(MessageType type) |
protected void |
DistributorAdapter.subscriptionChanged(SubscriptionProvider provider,
MessageType message) |
boolean |
OutputStreamMessageVisitor.visitData(DataProvider provider,
MessageType message) |
boolean |
OutputStreamComposer.visitData(DataProvider provider,
MessageType type) |
boolean |
MessageVisitor.visitData(DataProvider provider,
MessageType message)
This method consumes available data for data message from the given data provider.
|
boolean |
AbstractQTPComposer.visitData(DataProvider provider,
MessageType type)
This method consumes available data for data message from the given data provider.
|
abstract boolean |
AbstractMessageVisitor.visitData(DataProvider provider,
MessageType message)
This method consumes available data for data message from the given data provider.
|
protected boolean |
AgentAdapter.visitData(MessageVisitor visitor,
RecordProvider provider,
MessageType message) |
protected boolean |
DistributorAdapter.visitSubscription(MessageVisitor visitor,
SubscriptionProvider provider,
MessageType message) |
boolean |
OutputStreamMessageVisitor.visitSubscription(SubscriptionProvider provider,
MessageType message) |
boolean |
OutputStreamComposer.visitSubscription(SubscriptionProvider provider,
MessageType type) |
boolean |
MessageVisitor.visitSubscription(SubscriptionProvider provider,
MessageType message)
This method consumes available subscription for subscription message from the given subscription provider.
|
boolean |
AbstractQTPComposer.visitSubscription(SubscriptionProvider provider,
MessageType type)
This method consumes available subscription for subscription message from the given subscription provider.
|
abstract boolean |
AbstractMessageVisitor.visitSubscription(SubscriptionProvider provider,
MessageType message)
This method consumes available subscription for subscription message from the given subscription provider.
|
protected void |
BinaryQTPComposer.writeMessageHeader(MessageType messageType) |
protected abstract void |
AbstractQTPComposer.writeMessageHeader(MessageType messageType)
Composes header for a message of a specific type.
|
Copyright © 2002-2018 Devexperts LLC. All Rights Reserved.