com.devexperts.qd.qtp

Class DistributorAdapter.Factory

java.lang.Object

com.devexperts.connector.proto.ConfigurableObject

com.devexperts.qd.qtp.MessageAdapter.ConfigurableFactory

com.devexperts.qd.qtp.MessageAdapter.AbstractFactory

com.devexperts.qd.qtp.DistributorAdapter.Factory

All Implemented Interfaces:

ConfigurableMessageAdapterFactory, MessageAdapter.Factory, Cloneable

Enclosing class:

DistributorAdapter

public static class DistributorAdapter.Factory
extends MessageAdapter.AbstractFactory

The factory for distributor side of an QD.

Field Summary

Fields inherited from class com.devexperts.qd.qtp.MessageAdapter.AbstractFactory

endpoint, filter, history, scheme, stream, stripe, ticker

Constructor Summary

Constructors

Constructor and Description
Factory(QDCollector collector)
Factory(QDEndpoint endpoint, SubscriptionFilter filter)
Factory(QDHistory history)
Factory(QDStream stream)
Factory(QDTicker ticker)
Factory(QDTicker ticker, QDStream stream, QDHistory history, SubscriptionFilter filter) Creates new factory.

Method Summary

Modifier and Type	Method and Description
MessageAdapter	createAdapter(QDStats stats) Creates message adapter.
String	getFieldReplacer() Field Replacers specification for input data.
void	setFieldReplacer(String fieldReplacer) Set Field Replacers configuration for input data.

Methods inherited from class com.devexperts.qd.qtp.MessageAdapter.AbstractFactory

getCollectors, getFilter, getScheme, getStripe, getStripeFilter, setFilter, setStripeFilter, toString

Methods inherited from class com.devexperts.qd.qtp.MessageAdapter.ConfigurableFactory

clone, createMessageAdapterFactory, getEndpoint, setEndpoint

Methods inherited from class com.devexperts.connector.proto.ConfigurableObject

getConfiguration, reinitConfiguration, setConfiguration, supportedConfiguration

Methods inherited from class java.lang.Object

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

Constructor Detail

Factory

public Factory(QDTicker ticker,
               QDStream stream,
               QDHistory history,
               SubscriptionFilter filter)

Creates new factory. Accepts null parameters.

Factory

public Factory(QDEndpoint endpoint,
               SubscriptionFilter filter)

Factory

public Factory(QDTicker ticker)

Factory

public Factory(QDStream stream)

Factory

public Factory(QDHistory history)

Factory

public Factory(QDCollector collector)

Method Detail

createAdapter

public MessageAdapter createAdapter(QDStats stats)

Description copied from class: MessageAdapter.ConfigurableFactory

Creates message adapter.

Specified by:

createAdapter in interface MessageAdapter.Factory

Specified by:

createAdapter in class MessageAdapter.ConfigurableFactory

Parameters:

stats - stats node for the adapter.

Returns:

new message adapter.

getFieldReplacer

public String getFieldReplacer()

Field Replacers specification for input data.

setFieldReplacer

@Configurable(description="Field Replacers for input connection")
public void setFieldReplacer(String fieldReplacer)

Set Field Replacers configuration for input data.

Parameters:

fieldReplacer - field replacers configuration to process input data.