com.devexperts.qd.qtp

Class AgentAdapter.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.AgentAdapter.Factory

All Implemented Interfaces:

ConfigurableMessageAdapterFactory, MessageAdapter.Factory, Cloneable

Enclosing class:

AgentAdapter

public static class AgentAdapter.Factory
extends MessageAdapter.AbstractFactory

The factory for agent side of an QD.

Field Summary

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

endpoint, filter, history, scheme, stream, 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)

Method Summary

Modifier and Type	Method and Description
MessageAdapter	createAdapter(QDStats stats) Creates message adapter.
com.devexperts.util.TimePeriod	getAggregationPeriod()
String	getChannels()
Executor	getSubscriptionExecutor()
com.devexperts.util.TimePeriod	getSubscriptionKeepAlive()
int	getSubscriptionThreads()
void	setAggregationPeriod(com.devexperts.util.TimePeriod aggregationPeriod)
void	setChannels(String channels)
void	setSubscriptionExecutor(Executor subscriptionExecutor)
void	setSubscriptionKeepAlive(com.devexperts.util.TimePeriod keepAlive)
void	setSubscriptionThreads(int subscriptionThreads)

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)

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

getAggregationPeriod

public com.devexperts.util.TimePeriod getAggregationPeriod()

setAggregationPeriod

@Configurable(description="default aggregation period for all channels")
public void setAggregationPeriod(com.devexperts.util.TimePeriod aggregationPeriod)

getChannels

public String getChannels()

setChannels

@Configurable(description="channels configuration string")
public void setChannels(String channels)

getSubscriptionThreads

public int getSubscriptionThreads()

setSubscriptionThreads

@Configurable(description="size of the pool for subscription-handling threads\n(zero default - does not use separate thread pool for subscription)")
public void setSubscriptionThreads(int subscriptionThreads)

getSubscriptionExecutor

public Executor getSubscriptionExecutor()

setSubscriptionExecutor

@Configurable(description="explicit subscription executor")
public void setSubscriptionExecutor(Executor subscriptionExecutor)

getSubscriptionKeepAlive

@Nonnull
public com.devexperts.util.TimePeriod getSubscriptionKeepAlive()

setSubscriptionKeepAlive

@Configurable(description="subscription keep-alive period (0 or \'inf\')")
public void setSubscriptionKeepAlive(com.devexperts.util.TimePeriod keepAlive)

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.