org.opendaylight.mdsal.dom.spi.shard

Class DOMDataTreeListenerAggregator

java.lang.Object

org.opendaylight.mdsal.dom.spi.shard.AbstractStateAggregator<org.opendaylight.mdsal.dom.spi.shard.DOMDataTreeListenerAggregator.State>

org.opendaylight.mdsal.dom.spi.shard.DOMDataTreeListenerAggregator

@Beta
public final class DOMDataTreeListenerAggregator
extends AbstractStateAggregator<org.opendaylight.mdsal.dom.spi.shard.DOMDataTreeListenerAggregator.State>

Aggregator which combines multiple disjunct DOMDataTreeListener and forwards their changes to a central listener.

Author:

Robert Varga

Nested Class Summary

Nested classes/interfaces inherited from class org.opendaylight.mdsal.dom.spi.shard.AbstractStateAggregator

AbstractStateAggregator.Behavior<B extends AbstractStateAggregator.Behavior<B,S>,S extends AbstractStateAggregator.State>, AbstractStateAggregator.Failed<S extends AbstractStateAggregator.State>, AbstractStateAggregator.Started<S extends AbstractStateAggregator.State>

Constructor Summary

Constructors

Constructor and Description
DOMDataTreeListenerAggregator(int sizeHint, boolean allowRxMerges)

Method Summary

Modifier and Type	Method and Description
static <L extends DOMDataTreeListener,T> org.opendaylight.yangtools.concepts.ListenerRegistration<L>	aggregateIfNeeded(L listener, Map<T,Collection<DOMDataTreeIdentifier>> subtrees, boolean allowRxMerges, Function<T,DOMDataTreeShard> keyToShard)
DOMDataTreeListener	createListener()
<L extends DOMDataTreeListener> org.opendaylight.yangtools.concepts.ListenerRegistration<L>	start(L listener, Collection<org.opendaylight.yangtools.concepts.ListenerRegistration<DOMDataTreeListener>> regs)

Methods inherited from class org.opendaylight.mdsal.dom.spi.shard.AbstractStateAggregator

addBuilder, receiveState, start

Methods inherited from class java.lang.Object

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

Constructor Detail

DOMDataTreeListenerAggregator

public DOMDataTreeListenerAggregator(int sizeHint,
                                     boolean allowRxMerges)

Method Detail

aggregateIfNeeded

public static <L extends DOMDataTreeListener,T> org.opendaylight.yangtools.concepts.ListenerRegistration<L> aggregateIfNeeded(L listener,
                                                                                                                              Map<T,Collection<DOMDataTreeIdentifier>> subtrees,
                                                                                                                              boolean allowRxMerges,
                                                                                                                              Function<T,DOMDataTreeShard> keyToShard)

createListener

public DOMDataTreeListener createListener()

start

public <L extends DOMDataTreeListener> org.opendaylight.yangtools.concepts.ListenerRegistration<L> start(L listener,
                                                                                                         Collection<org.opendaylight.yangtools.concepts.ListenerRegistration<DOMDataTreeListener>> regs)