org.opendaylight.controller.messagebus.app.impl

Class EventSourceTopology

java.lang.Object

org.opendaylight.controller.messagebus.app.impl.EventSourceTopology

All Implemented Interfaces:

AutoCloseable, EventSourceRegistry, EventAggregatorService, org.opendaylight.yangtools.yang.binding.RpcService

public class EventSourceTopology
extends Object
implements EventAggregatorService, EventSourceRegistry

Constructor Summary

Constructors

Constructor and Description
EventSourceTopology(DataBroker dataBroker, RpcProviderRegistry rpcRegistry)

Method Summary

Modifier and Type	Method and Description
void	close()
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<CreateTopicOutput>>	createTopic(CreateTopicInput input) Create a new topic.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<DestroyTopicOutput>>	destroyTopic(DestroyTopicInput input) Destroy a topic.
void	register(EventSource eventSource)
<T extends EventSource> EventSourceRegistration<T>	registerEventSource(T eventSource) Registers the given EventSource for public consumption.
void	unRegister(EventSource eventSource)

Methods inherited from class java.lang.Object

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

Constructor Detail

EventSourceTopology

public EventSourceTopology(DataBroker dataBroker,
                           RpcProviderRegistry rpcRegistry)

Method Detail

createTopic

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<CreateTopicOutput>> createTopic(CreateTopicInput input)

Description copied from interface: EventAggregatorService

Create a new topic. A topic is an aggregation of several notificationtypes from a set of nodes. Each successful invocation results in a uniquetopic being created. The caller is responsible for removing the topiconce it is no longer needed.

Specified by:

createTopic in interface EventAggregatorService

destroyTopic

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<DestroyTopicOutput>> destroyTopic(DestroyTopicInput input)

Description copied from interface: EventAggregatorService

Destroy a topic. No further messages will be delivered to it.

Specified by:

destroyTopic in interface EventAggregatorService

close

public void close()

Specified by:

close in interface AutoCloseable

register

public void register(EventSource eventSource)

unRegister

public void unRegister(EventSource eventSource)

registerEventSource

public <T extends EventSource> EventSourceRegistration<T> registerEventSource(T eventSource)

Description copied from interface: EventSourceRegistry

Registers the given EventSource for public consumption. The EventSource is associated with the node identified via EventSource.getSourceNodeKey().

Specified by:

registerEventSource in interface EventSourceRegistry

Parameters:

eventSource - the EventSource instance to register

Returns:

an EventSourceRegistration instance that is used to unregister the EventSource via EventSourceRegistration.close().