com.devexperts.qd.qtp

Class QDEndpoint.Builder

java.lang.Object

com.devexperts.qd.qtp.QDEndpoint.Builder

All Implemented Interfaces:

Cloneable

Enclosing class:

QDEndpoint

@Service
public static class QDEndpoint.Builder
extends Object
implements Cloneable

Builder that creates instances of QDEndpoint objects.

Field Summary

Fields

Modifier and Type	Field and Description
protected List<QDCollector.Factory>	collectors
protected Properties	props
protected DataScheme	scheme
protected boolean	storeEverything
protected SymbolStriper	striper
protected boolean	withEventTimeSequence

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	Builder() Creates new builder.

Method Summary

Modifier and Type	Method and Description
QDEndpoint	build()
QDEndpoint.Builder	clone()
protected String	getOrCreateName()
protected DataScheme	getSchemeOrDefault()
protected SymbolStriper	getStriperOrDefault()
protected void	subscribe(QDEndpoint endpoint)
boolean	supportsProperty(String key) Returns true if the corresponding property key is supported.
QDEndpoint.Builder	withCollectors(Collection<? extends QDCollector.Factory> collectors) Creates specified collectors for this endpoint when it is build().
QDEndpoint.Builder	withContracts(EnumSet<QDContract> contracts) Deprecated. Use withCollectors(Collection) and it has a more telling name and wider range of features.
QDEndpoint.Builder	withEventTimeSequence(boolean withEventTime) Specifies should endpoint support event time sequence or not.
QDEndpoint.Builder	withName(String name) Changes name that is used to distinguish multiple endpoints in the same JVM in logs and in other diagnostic means.
QDEndpoint.Builder	withProperties(Properties props) Sets all supported properties from the provided properties object.
QDEndpoint.Builder	withProperty(String key, String value) Sets the specified property.
QDEndpoint.Builder	withScheme(DataScheme scheme)
QDEndpoint.Builder	withStoreEverything(boolean storeEverything) Invoke this method to enable store everything mode in endpoint's collectors.
QDEndpoint.Builder	withStripe(String stripe)
QDEndpoint.Builder	withStriper(SymbolStriper striper)
QDEndpoint.Builder	withSubscribeSupport(String prefix) Invoke this method with a property key prefix like "dxfeed.qd.subscribe." or "multiplexor.qd.subscribe." to enable support for permanent subscription.

Methods inherited from class java.lang.Object

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

Field Detail

scheme

protected DataScheme scheme

collectors

protected List<QDCollector.Factory> collectors

props

protected Properties props

withEventTimeSequence

protected boolean withEventTimeSequence

storeEverything

protected boolean storeEverything

striper

protected SymbolStriper striper

Constructor Detail

Builder

protected Builder()

Creates new builder. This method is for extension only. Don't use it directly. Use QDEndpoint.newBuilder().

Method Detail

clone

public QDEndpoint.Builder clone()

Overrides:

clone in class Object

withName

public final QDEndpoint.Builder withName(String name)

Changes name that is used to distinguish multiple endpoints in the same JVM in logs and in other diagnostic means. This is a shortcut for withProperty(NAME_PROPERTY,name)

withScheme

public final QDEndpoint.Builder withScheme(DataScheme scheme)

withContracts

public final QDEndpoint.Builder withContracts(EnumSet<QDContract> contracts)

Deprecated. Use withCollectors(Collection) and it has a more telling name and wider range of features.

withCollectors

public final QDEndpoint.Builder withCollectors(Collection<? extends QDCollector.Factory> collectors)

Creates specified collectors for this endpoint when it is build().

withEventTimeSequence

public final QDEndpoint.Builder withEventTimeSequence(boolean withEventTime)

Specifies should endpoint support event time sequence or not.

Parameters:

withEventTime - true if endpoint should support event time sequence.

withStoreEverything

public final QDEndpoint.Builder withStoreEverything(boolean storeEverything)

Invoke this method to enable store everything mode in endpoint's collectors.

withStripe

public final QDEndpoint.Builder withStripe(String stripe)

withStriper

public final QDEndpoint.Builder withStriper(SymbolStriper striper)

withSubscribeSupport

public final QDEndpoint.Builder withSubscribeSupport(String prefix)

Invoke this method with a property key prefix like "dxfeed.qd.subscribe." or "multiplexor.qd.subscribe." to enable support for permanent subscription. This method should be invoked before withProperties(Properties). This prefix together with a QDContract name provides a way to define a permanent subscription for a specified contract with the value of "<records> <symbols>".

withProperty

public final QDEndpoint.Builder withProperty(String key,
                                             String value)

Sets the specified property. Unsupported properties are ignored.

See Also:

supportsProperty(String)

withProperties

public final QDEndpoint.Builder withProperties(Properties props)

Sets all supported properties from the provided properties object.

supportsProperty

public boolean supportsProperty(String key)

Returns true if the corresponding property key is supported.

See Also:

withProperty(String, String)

getOrCreateName

protected final String getOrCreateName()

getSchemeOrDefault

protected final DataScheme getSchemeOrDefault()

getStriperOrDefault

protected final SymbolStriper getStriperOrDefault()

build

public QDEndpoint build()

subscribe

protected void subscribe(QDEndpoint endpoint)