com.devexperts.qd.qtp

Class DynamicChannelShaper

java.lang.Object

com.devexperts.qd.qtp.ChannelShaper

com.devexperts.qd.qtp.DynamicChannelShaper

All Implemented Interfaces:

QDFilter.UpdateListener, Cloneable

public class DynamicChannelShaper
extends ChannelShaper
implements QDFilter.UpdateListener

Constructor Summary

Constructors

Constructor and Description
DynamicChannelShaper(QDContract contract, Executor subscriptionExecutor, QDFilter subscriptionFilter)

Method Summary

Modifier and Type	Method and Description
DynamicChannelShaper	clone()
void	close() Closes this channel shaper and releases its resources (stops tracking dynamic filters).
void	filterUpdated(QDFilter filter) This method is fired at most once is a lifetime of a dynamic filter when it updates.
void	setSubscriptionFilter(QDFilter subscriptionFilter) Sets subscription filter for the channel.
void	updateFilter()

Methods inherited from class com.devexperts.qd.qtp.ChannelShaper

getAggregationPeriod, getCollector, getContract, getDataFilter, getSubscriptionExecutor, getSubscriptionFilter, getWeight, hasSubscriptionExecutor, isKeepRejected, setAggregationPeriod, setCollector, setDataFilter, setSubscriptionFilter, setWeight

Methods inherited from class java.lang.Object

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

Constructor Detail

DynamicChannelShaper

public DynamicChannelShaper(QDContract contract,
                            Executor subscriptionExecutor,
                            QDFilter subscriptionFilter)

Method Detail

clone

public DynamicChannelShaper clone()

Overrides:

clone in class ChannelShaper

setSubscriptionFilter

public void setSubscriptionFilter(QDFilter subscriptionFilter)

Description copied from class: ChannelShaper

Sets subscription filter for the channel. Use QDFilter.ANYTHING to accept any subscription. Change of subscription filter will trigger re-creation of agent.

Overrides:

setSubscriptionFilter in class ChannelShaper

Parameters:

subscriptionFilter - subscription filter; may be null for backwards-compatibility (it is replaced with QDFilter.ANYTHING)

updateFilter

public void updateFilter()

filterUpdated

public void filterUpdated(QDFilter filter)

Description copied from interface: QDFilter.UpdateListener

This method is fired at most once is a lifetime of a dynamic filter when it updates. The new value of the filter shall be retrieved with QDFilter.getUpdatedFilter() method. This method is never called under synchronization on any filter to avoid deadlocks.

Specified by:

filterUpdated in interface QDFilter.UpdateListener

Parameters:

filter - The filter that was updated. Use filter.getUpdateFilter() to get the new instance of the updated filter.

close

public void close()

Description copied from class: ChannelShaper

Closes this channel shaper and releases its resources (stops tracking dynamic filters).

Overrides:

close in class ChannelShaper