com.devexperts.qd.qtp

Class MessageAdapter.AbstractFactory

java.lang.Object

com.devexperts.connector.proto.ConfigurableObject

com.devexperts.qd.qtp.MessageAdapter.ConfigurableFactory

com.devexperts.qd.qtp.MessageAdapter.AbstractFactory

All Implemented Interfaces:

ConfigurableMessageAdapterFactory, MessageAdapter.Factory, Cloneable

Direct Known Subclasses:

AgentAdapter.Factory, DistributorAdapter.Factory

Enclosing class:

MessageAdapter

public abstract static class MessageAdapter.AbstractFactory
extends MessageAdapter.ConfigurableFactory

An abstract message adapter factory for QDEndpoint or a bunch of QDCollector instances. It has built in support of a FILTER_CONFIGURATION_KEY that is aligned with a legacy ConfigurableMessageAdapterFactory interface.

Field Summary

Fields

Modifier and Type	Field and Description
protected QDEndpoint	endpoint
protected QDFilter	filter
protected QDHistory	history
protected DataScheme	scheme
protected QDStream	stream
protected QDFilter	stripe
protected QDTicker	ticker

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractFactory(QDEndpoint endpoint, SubscriptionFilter filter)
protected	AbstractFactory(QDTicker ticker, QDStream stream, QDHistory history, SubscriptionFilter filter) Creates new factory.

Method Summary

Modifier and Type	Method and Description
QDCollector[]	getCollectors()
QDFilter	getFilter() Returns current filter of this factory.
DataScheme	getScheme()
QDFilter	getStripe()
String	getStripeFilter()
void	setFilter(String filterString) Sets additional filter for this factory.
void	setStripeFilter(String stripeString) Sets stripe (represented as QDFilter) for this factory.
String	toString() Returns description of this factory for management and logging purposes.

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

clone, createAdapter, 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

Field Detail

endpoint

protected final QDEndpoint endpoint

scheme

protected final DataScheme scheme

ticker

protected final QDTicker ticker

stream

protected final QDStream stream

history

protected final QDHistory history

filter

@Nonnull
protected QDFilter filter

stripe

@Nonnull
protected QDFilter stripe

Constructor Detail

AbstractFactory

protected AbstractFactory(QDTicker ticker,
                          QDStream stream,
                          QDHistory history,
                          SubscriptionFilter filter)

Creates new factory. Accepts null parameters.

Parameters:

ticker - QDTicker to use.

stream - QDStream to use.

history - QDHistory to use.

filter - SubscriptionFilter to use.

AbstractFactory

protected AbstractFactory(QDEndpoint endpoint,
                          SubscriptionFilter filter)

Method Detail

getScheme

public DataScheme getScheme()

getCollectors

public QDCollector[] getCollectors()

getFilter

public QDFilter getFilter()

Returns current filter of this factory. It is a result of combining initial filter and stripe with the filter set by setFilter(String) method.

Returns:

current filter of this factory.

setFilter

@Configurable(description="default filter for all channels")
public void setFilter(String filterString)
                                                                            throws FilterSyntaxException

Sets additional filter for this factory. This filter is parsed and added using "and" operation to the initial filter that was specified in constructor.

Parameters:

filterString - filter for this message adapter.

Throws:

FilterSyntaxException - if filter string is invalid.

getStripe

@Nonnull
public QDFilter getStripe()

getStripeFilter

@Nonnull
public String getStripeFilter()

setStripeFilter

@Configurable(description="default stripe for all channels")
public void setStripeFilter(String stripeString)

Sets stripe (represented as QDFilter) for this factory.

Parameters:

stripeString - stripe for this message adapter.

Throws:

FilterSyntaxException - if stripe filter specification is invalid.

toString

public String toString()

Description copied from class: MessageAdapter.ConfigurableFactory

Returns description of this factory for management and logging purposes.

Overrides:

toString in class MessageAdapter.ConfigurableFactory