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(org.opendaylight.mdsal.binding.api.DataBroker dataBroker, org.opendaylight.mdsal.binding.api.RpcProviderService providerService, org.opendaylight.mdsal.binding.api.RpcConsumerRegistry rpcService)

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(org.opendaylight.mdsal.binding.api.DataBroker dataBroker,
                           org.opendaylight.mdsal.binding.api.RpcProviderService providerService,
                           org.opendaylight.mdsal.binding.api.RpcConsumerRegistry rpcService)

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 notification types from a set of nodes. Each successful invocation results in a unique topic being created. The caller is responsible for removing the topic once 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().