com.devexperts.qd.qtp

Class MessageConnectors

java.lang.Object

com.devexperts.qd.qtp.MessageConnectors

public class MessageConnectors
extends Object

Factory and utility classes to work with message connectors.

See Also:

MessageConnector

Field Summary

Fields

Modifier and Type	Field and Description
static com.devexperts.connector.proto.ConfigurationKey<String>	FIELD_REPLACER_CONFIGURATION_KEY
static com.devexperts.connector.proto.ConfigurationKey<String>	FILTER_CONFIGURATION_KEY
static com.devexperts.util.TypedKey<QDFilter>	LOCAL_STRIPE_KEY
static com.devexperts.connector.proto.ConfigurationKey<Integer>	MAX_CONNECTIONS_CONFIGURATION_KEY
static com.devexperts.connector.proto.ConfigurationKey<String>	NAME_CONFIGURATION_KEY
static com.devexperts.connector.proto.ConfigurationKey<String>	PASSWORD_CONFIGURATION_KEY
static com.devexperts.util.TypedKey<Socket>	SOCKET_KEY
static com.devexperts.util.TypedKey<QDStats>	STATS_KEY
static com.devexperts.connector.proto.ConfigurationKey<String>	STRIPE_FILTER_CONFIGURATION_KEY
static com.devexperts.connector.proto.ConfigurationKey<String>	USER_CONFIGURATION_KEY

Constructor Summary

Constructors

Constructor and Description
MessageConnectors()

Method Summary

Modifier and Type	Method and Description
static void	addMessageConnectorListener(Collection<? extends MessageConnector> connectors, MessageConnectorListener listener)
static com.devexperts.connector.proto.ApplicationConnectionFactory	applicationConnectionFactory(ConfigurableMessageAdapterFactory factory)
static com.devexperts.connector.proto.ApplicationConnectionFactory	applicationConnectionFactory(MessageAdapter.Factory factory)
static ConfigurableMessageAdapterFactory	configurable(MessageAdapter.Factory factory) Deprecated. This class has a deprecated return type. Use configurableFactory(MessageAdapter.Factory).
static MessageAdapter.ConfigurableFactory	configurableFactory(MessageAdapter.Factory factory) Wraps any MessageAdapter.Factory into ConfigurableMessageAdapterFactory if necessary, so that it can be used with createMessageConnectors(com.devexperts.qd.qtp.ConfigurableMessageAdapterFactory, java.lang.String, com.devexperts.qd.stats.QDStats) method, but does not accept any additional specification for factory.
static List<MessageConnector>	createMessageConnectors(com.devexperts.connector.proto.ApplicationConnectionFactory acFactory, String addresses)
static List<MessageConnector>	createMessageConnectors(com.devexperts.connector.proto.ApplicationConnectionFactory acFactory, String addresses, QDStats stats)
static List<MessageConnector>	createMessageConnectors(ConfigurableMessageAdapterFactory cFactory, String addresses, QDStats parentStats) Creates new connectors for specified addresses using specified configurable adapter factory.
static Class<? extends MessageConnector>	findMessageConnector(String name, ClassLoader loader) Finds MessageConnector class by its short name (case-insensitive).
static <T extends com.devexperts.connector.codec.CodecConnectionFactory> T	getCodecFactory(com.devexperts.connector.proto.ApplicationConnectionFactory factory, Class<T> codecFactoryClass)
static com.devexperts.transport.stats.EndpointStats	getEndpointStats(Collection<? extends MessageConnector> connectors)
static List<Class<? extends MessageConnector>>	listMessageConnectors(ClassLoader loader)
static String	maskAuthorizationData(String address) Deprecated. use LogUtil.hideCredentials(java.lang.Object) instead
static void	removeMessageConnectorListener(Collection<? extends MessageConnector> connectors, MessageConnectorListener listener)
static MessageAdapter.Factory	retrieveMessageAdapterFactory(com.devexperts.connector.proto.ApplicationConnectionFactory pFactory)
static void	setThreadPriority(Collection<? extends MessageConnector> connectors, int priority)
static void	startMessageConnectors(Collection<? extends MessageConnector> connectors)
static void	stopMessageConnectors(Collection<? extends MessageConnector> connectors)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

NAME_CONFIGURATION_KEY

public static final com.devexperts.connector.proto.ConfigurationKey<String> NAME_CONFIGURATION_KEY

FILTER_CONFIGURATION_KEY

public static final com.devexperts.connector.proto.ConfigurationKey<String> FILTER_CONFIGURATION_KEY

STRIPE_FILTER_CONFIGURATION_KEY

public static final com.devexperts.connector.proto.ConfigurationKey<String> STRIPE_FILTER_CONFIGURATION_KEY

USER_CONFIGURATION_KEY

public static final com.devexperts.connector.proto.ConfigurationKey<String> USER_CONFIGURATION_KEY

PASSWORD_CONFIGURATION_KEY

public static final com.devexperts.connector.proto.ConfigurationKey<String> PASSWORD_CONFIGURATION_KEY

FIELD_REPLACER_CONFIGURATION_KEY

public static final com.devexperts.connector.proto.ConfigurationKey<String> FIELD_REPLACER_CONFIGURATION_KEY

MAX_CONNECTIONS_CONFIGURATION_KEY

public static final com.devexperts.connector.proto.ConfigurationKey<Integer> MAX_CONNECTIONS_CONFIGURATION_KEY

SOCKET_KEY

public static final com.devexperts.util.TypedKey<Socket> SOCKET_KEY

STATS_KEY

public static final com.devexperts.util.TypedKey<QDStats> STATS_KEY

LOCAL_STRIPE_KEY

public static final com.devexperts.util.TypedKey<QDFilter> LOCAL_STRIPE_KEY

Constructor Detail

MessageConnectors

public MessageConnectors()

Method Detail

configurable

public static ConfigurableMessageAdapterFactory configurable(MessageAdapter.Factory factory)

Deprecated. This class has a deprecated return type. Use configurableFactory(MessageAdapter.Factory).

Wraps any MessageAdapter.Factory into ConfigurableMessageAdapterFactory if necessary, so that it can be used with createMessageConnectors(com.devexperts.qd.qtp.ConfigurableMessageAdapterFactory, java.lang.String, com.devexperts.qd.stats.QDStats) method, but does not accept any additional specification for factory.

Parameters:

factory - MessageAdapter.Factory to wrap

Returns:

ConfigurableMessageAdapterFactory

configurableFactory

public static MessageAdapter.ConfigurableFactory configurableFactory(MessageAdapter.Factory factory)

Wraps any MessageAdapter.Factory into ConfigurableMessageAdapterFactory if necessary, so that it can be used with createMessageConnectors(com.devexperts.qd.qtp.ConfigurableMessageAdapterFactory, java.lang.String, com.devexperts.qd.stats.QDStats) method, but does not accept any additional specification for factory. This method return null when the argument is null.

Parameters:

factory - MessageAdapter.Factory to wrap

Returns:

ConfigurableMessageAdapterFactory

applicationConnectionFactory

public static com.devexperts.connector.proto.ApplicationConnectionFactory applicationConnectionFactory(MessageAdapter.Factory factory)

applicationConnectionFactory

public static com.devexperts.connector.proto.ApplicationConnectionFactory applicationConnectionFactory(ConfigurableMessageAdapterFactory factory)

retrieveMessageAdapterFactory

public static MessageAdapter.Factory retrieveMessageAdapterFactory(com.devexperts.connector.proto.ApplicationConnectionFactory pFactory)

createMessageConnectors

public static List<MessageConnector> createMessageConnectors(ConfigurableMessageAdapterFactory cFactory,
                                                             String addresses,
                                                             QDStats parentStats)
                                                      throws AddressSyntaxException

Creates new connectors for specified addresses using specified configurable adapter factory. The addresses string can contain one address or multiple addresses to configure multiple connectors:

• <address>
• (<address>)(<address>)... - first way to specify multiple addresses.
• <address>/<address>/... - second way to specify multiple addresses.

The individual address format is: [<spec>@]<connector>[(<name>=<value>)[(...)]]. Spec (optional) is processed by the configurable message adapter factory. Name-value pairs (optional) specify additional bean properties for connectors (see corresponding class definitions). The individual connector format is one of:

• [tls+][<host>[:<port>],[...,]]<host>:<port> - for client TCP/IP socket. See ClientSocketConnector.
• [tls+]:<port> - for server TCP/IP socket. See ServerSocketConnector.

Note that last port number is mandatory, and it will be used for all listed hosts unless overridden individually. Optional TLS (Transport Layer Security) specifier turns on SSL/TLS for the corresponding connector.

Example of the addresses string is
(equities@quote01:5001)(options@quote02:5001)(messages@m1,m2:5002)(:5003)

Parameters:

cFactory - Configurable message adapter factory.

addresses - The addresses string.

parentStats - Parent QDStats for all created connectors.

Returns:

A list of messages connectors implementing MessageConnector interface

Throws:

NullPointerException - if any parameter is null

AddressSyntaxException - if address format is incorrect

createMessageConnectors

public static List<MessageConnector> createMessageConnectors(com.devexperts.connector.proto.ApplicationConnectionFactory acFactory,
                                                             String addresses,
                                                             QDStats stats)
                                                      throws AddressSyntaxException

Throws:

AddressSyntaxException

createMessageConnectors

public static List<MessageConnector> createMessageConnectors(com.devexperts.connector.proto.ApplicationConnectionFactory acFactory,
                                                             String addresses)
                                                      throws AddressSyntaxException

Throws:

AddressSyntaxException

maskAuthorizationData

@Deprecated
public static String maskAuthorizationData(String address)

Deprecated. use LogUtil.hideCredentials(java.lang.Object) instead

listMessageConnectors

public static List<Class<? extends MessageConnector>> listMessageConnectors(ClassLoader loader)

findMessageConnector

public static Class<? extends MessageConnector> findMessageConnector(String name,
                                                                     ClassLoader loader)

Finds MessageConnector class by its short name (case-insensitive).

Parameters:

name - MessageConnector class name.

loader - Class loader to use.

Returns:

corresponding Class<? extends MessageConnector> or null if no such MessageConnector was found.

getCodecFactory

public static <T extends com.devexperts.connector.codec.CodecConnectionFactory> T getCodecFactory(com.devexperts.connector.proto.ApplicationConnectionFactory factory,
                                                                                                  Class<T> codecFactoryClass)

startMessageConnectors

public static void startMessageConnectors(Collection<? extends MessageConnector> connectors)

stopMessageConnectors

public static void stopMessageConnectors(Collection<? extends MessageConnector> connectors)

getEndpointStats

public static com.devexperts.transport.stats.EndpointStats getEndpointStats(Collection<? extends MessageConnector> connectors)

addMessageConnectorListener

public static void addMessageConnectorListener(Collection<? extends MessageConnector> connectors,
                                               MessageConnectorListener listener)

removeMessageConnectorListener

public static void removeMessageConnectorListener(Collection<? extends MessageConnector> connectors,
                                                  MessageConnectorListener listener)

setThreadPriority

public static void setThreadPriority(Collection<? extends MessageConnector> connectors,
                                     int priority)