|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.devexperts.qd.qtp.MessageConnectors
public class MessageConnectors
Factory and utility classes to work with message connectors.
MessageConnector
Field Summary | |
---|---|
static com.devexperts.connector.proto.ConfigurationKey<java.lang.String> |
FILTER_CONFIGURATION_KEY
|
static com.devexperts.util.TypedKey<java.net.Socket> |
SOCKET_KEY
|
static com.devexperts.util.TypedKey<QDStats> |
STATS_KEY
|
Constructor Summary | |
---|---|
MessageConnectors()
|
Method Summary | |
---|---|
static void |
addMessageConnectorListener(java.util.Collection<? extends MessageConnector> connectors,
MessageConnectorListener listener)
|
static com.devexperts.connector.proto.ApplicationConnectionFactory |
applicationConnectionFactory(ConfigurableMessageAdapterFactory cfactory)
|
static com.devexperts.connector.proto.ApplicationConnectionFactory |
applicationConnectionFactory(MessageAdapter.Factory factory)
|
static ConfigurableMessageAdapterFactory |
configurable(MessageAdapter.Factory factory)
Wraps any MessageAdapter.Factory into ConfigurableMessageAdapterFactory if
neccessary, 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 java.util.List<MessageConnector> |
createMessageConnectors(com.devexperts.connector.proto.ApplicationConnectionFactory acfactory,
java.lang.String addresses)
|
static java.util.List<MessageConnector> |
createMessageConnectors(com.devexperts.connector.proto.ApplicationConnectionFactory acfactory,
java.lang.String addresses,
QDStats stats)
|
static java.util.List<MessageConnector> |
createMessageConnectors(ConfigurableMessageAdapterFactory cfactory,
java.lang.String addresses,
QDStats parentStats)
Creates new connectors for specified addresses using specified configurable adapter factory. |
static java.lang.Class<? extends MessageConnector> |
findMessageConnector(java.lang.String name,
java.lang.ClassLoader loader)
Finds MessageConnector class by its short name (case-insensitive). |
static com.devexperts.transport.stats.EndpointStats |
getEndpointStats(java.util.Collection<? extends MessageConnector> connectors)
|
static java.lang.Class<? extends MessageConnector>[] |
listMessageConnectors(java.lang.ClassLoader loader)
|
static void |
removeMessageConnectorListener(java.util.Collection<? extends MessageConnector> connectors,
MessageConnectorListener listener)
|
static MessageAdapter.Factory |
retrieveMessageAdapterFactory(com.devexperts.connector.proto.ApplicationConnectionFactory pfactory)
Deprecated. |
static void |
setThreadPriority(java.util.Collection<? extends MessageConnector> connectors,
int priority)
|
static void |
startMessageConnectors(java.util.Collection<? extends MessageConnector> connectors)
|
static void |
stopMessageConnectors(java.util.Collection<? extends MessageConnector> connectors)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final com.devexperts.connector.proto.ConfigurationKey<java.lang.String> FILTER_CONFIGURATION_KEY
public static com.devexperts.util.TypedKey<java.net.Socket> SOCKET_KEY
public static com.devexperts.util.TypedKey<QDStats> STATS_KEY
Constructor Detail |
---|
public MessageConnectors()
Method Detail |
---|
public static ConfigurableMessageAdapterFactory configurable(MessageAdapter.Factory factory)
MessageAdapter.Factory
into ConfigurableMessageAdapterFactory
if
neccessary, 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.
factory
- MessageAdapter.Factory
to wrap
ConfigurableMessageAdapterFactory
public static com.devexperts.connector.proto.ApplicationConnectionFactory applicationConnectionFactory(MessageAdapter.Factory factory)
public static com.devexperts.connector.proto.ApplicationConnectionFactory applicationConnectionFactory(ConfigurableMessageAdapterFactory cfactory)
@Deprecated public static MessageAdapter.Factory retrieveMessageAdapterFactory(com.devexperts.connector.proto.ApplicationConnectionFactory pfactory)
public static java.util.List<MessageConnector> createMessageConnectors(ConfigurableMessageAdapterFactory cfactory, java.lang.String addresses, QDStats parentStats) throws AddressSyntaxException
HttpConnector
.
ClientSocketConnector
.
ServerSocketConnector
.
Example of the addresses string is
(equities@quote01:5001)(options@quote02:5001)(messages@m1,m2:5002)(:5003)
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:
java.lang.NullPointerException
- if any parameter is null
AddressSyntaxException
- if address format is incorrect
public static java.util.List<MessageConnector> createMessageConnectors(com.devexperts.connector.proto.ApplicationConnectionFactory acfactory, java.lang.String addresses, QDStats stats) throws AddressSyntaxException
AddressSyntaxException
public static java.util.List<MessageConnector> createMessageConnectors(com.devexperts.connector.proto.ApplicationConnectionFactory acfactory, java.lang.String addresses) throws AddressSyntaxException
AddressSyntaxException
public static java.lang.Class<? extends MessageConnector>[] listMessageConnectors(java.lang.ClassLoader loader)
public static java.lang.Class<? extends MessageConnector> findMessageConnector(java.lang.String name, java.lang.ClassLoader loader)
name
- MessageConnector class name.loader
- Class loader to use.
public static void startMessageConnectors(java.util.Collection<? extends MessageConnector> connectors)
public static void stopMessageConnectors(java.util.Collection<? extends MessageConnector> connectors)
public static com.devexperts.transport.stats.EndpointStats getEndpointStats(java.util.Collection<? extends MessageConnector> connectors)
public static void addMessageConnectorListener(java.util.Collection<? extends MessageConnector> connectors, MessageConnectorListener listener)
public static void removeMessageConnectorListener(java.util.Collection<? extends MessageConnector> connectors, MessageConnectorListener listener)
public static void setThreadPriority(java.util.Collection<? extends MessageConnector> connectors, int priority)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |