public final class ProtocolDescriptor extends Object
DESCRIBE_PROTOCOL
message.Modifier and Type | Field and Description |
---|---|
static String |
AUTHENTICATION_PROPERTY |
static String |
AUTHORIZATION_PROPERTY |
static String |
BASIC_AUTHORIZATION |
static String |
FILTER_PROPERTY |
static String |
MAGIC_STRING
This string identifies protocol descriptor message.
|
static String |
NAME_PROPERTY |
static String |
OPT_PROPERTY |
static String |
RMI_PROPERTY |
static String |
SERVICES_PROPERTY |
static String |
STRIPE_PROPERTY |
static String |
TIME_PROPERTY |
static String |
TYPE_PROPERTY |
static String |
VERSION_PROPERTY |
Modifier and Type | Method and Description |
---|---|
void |
addReceive(MessageDescriptor message) |
void |
addSend(MessageDescriptor message) |
int |
appendFromTextTokens(List<String> tokens,
int i)
Adds information to this protocol descriptor from a list of strings that are parsed
from tab or comma separated text format.
|
boolean |
canReceive(MessageType message) |
boolean |
canSend(MessageType message) |
void |
composeTo(com.devexperts.io.BufferedOutput out)
Composes this protocol descriptor in compact binary format
including its
MAGIC_STRING . |
List<String> |
convertToTextTokens()
Converts this protocol descriptor to a list of strings for representation in tab or comma separated text format.
|
com.devexperts.connector.proto.EndpointId |
getEndpointId() |
Map<String,String> |
getProperties() |
String |
getProperty(String key) |
MessageDescriptor |
getReceive(MessageType message) |
Set<MessageDescriptor> |
getReceiveMessages() |
EnumSet<MessageType> |
getReceiveSet() |
MessageDescriptor |
getSend(MessageType message) |
Set<MessageDescriptor> |
getSendMessages() |
EnumSet<MessageType> |
getSendSet() |
MessageDescriptor |
newMessageDescriptor() |
MessageDescriptor |
newMessageDescriptor(MessageType messageType) |
static ProtocolDescriptor |
newPeerProtocolDescriptor(ProtocolDescriptor previouslyRead) |
static ProtocolDescriptor |
newPeerProtocolDescriptorReadAs(ProtocolDescriptor original,
MessageType readAs) |
static ProtocolDescriptor |
newSelfProtocolDescriptor(String type)
Creates empty protocol description for a specified type with an embedded QDS version.
|
void |
parseFrom(com.devexperts.io.BufferedInput in)
Parses protocol descriptor from compact binary format
including its
MAGIC_STRING . |
void |
setEndpointId(com.devexperts.connector.proto.EndpointId endpointId) |
void |
setProperty(String key,
String value) |
String |
toString() |
public static final String MAGIC_STRING
public static final String TYPE_PROPERTY
public static final String VERSION_PROPERTY
public static final String OPT_PROPERTY
public static final String TIME_PROPERTY
public static final String NAME_PROPERTY
public static final String FILTER_PROPERTY
public static final String STRIPE_PROPERTY
public static final String SERVICES_PROPERTY
public static final String AUTHORIZATION_PROPERTY
public static final String AUTHENTICATION_PROPERTY
public static final String RMI_PROPERTY
public static final String BASIC_AUTHORIZATION
public static ProtocolDescriptor newSelfProtocolDescriptor(String type)
type
- the type.public static ProtocolDescriptor newPeerProtocolDescriptor(ProtocolDescriptor previouslyRead)
public static ProtocolDescriptor newPeerProtocolDescriptorReadAs(ProtocolDescriptor original, MessageType readAs)
public MessageDescriptor newMessageDescriptor()
public MessageDescriptor newMessageDescriptor(MessageType messageType)
public com.devexperts.connector.proto.EndpointId getEndpointId()
public void setEndpointId(com.devexperts.connector.proto.EndpointId endpointId)
public Set<MessageDescriptor> getSendMessages()
public Set<MessageDescriptor> getReceiveMessages()
public boolean canSend(MessageType message)
public boolean canReceive(MessageType message)
public EnumSet<MessageType> getSendSet()
public MessageDescriptor getSend(MessageType message)
public EnumSet<MessageType> getReceiveSet()
public MessageDescriptor getReceive(MessageType message)
public void addSend(MessageDescriptor message)
public void addReceive(MessageDescriptor message)
public void composeTo(com.devexperts.io.BufferedOutput out) throws IOException
MAGIC_STRING
.IOException
public void parseFrom(com.devexperts.io.BufferedInput in) throws IOException
MAGIC_STRING
.IOException
- when descriptor cannot be read due to wrong magic or other reasons.public List<String> convertToTextTokens()
MAGIC_STRING
.public int appendFromTextTokens(List<String> tokens, int i)
Copyright © 2002–2025 Devexperts LLC. All rights reserved.