org.opennms.netmgt.telemetry.distributed.minion

Class ListenerManager

java.lang.Object

org.opennms.netmgt.telemetry.distributed.minion.ListenerManager

All Implemented Interfaces:

org.osgi.service.cm.ManagedServiceFactory

public class ListenerManager
extends Object
implements org.osgi.service.cm.ManagedServiceFactory

This ManagedServiceFactory for service pids that contain telemetry listener definitions and manages their lifecycle by starting/updating and stopping them accordingly. See MapBasedListenerDef for a list of supported properties.

Author:

jwhite

Constructor Summary

Constructors

Constructor and Description
ListenerManager()

Method Summary

Modifier and Type	Method and Description
void	deleted(String pid)
void	destroy()
DistPollerDao	getDistPollerDao()
MessageDispatcherFactory	getMessageDispatcherFactory()
String	getName()
void	init()
void	setBundleContext(org.osgi.framework.BundleContext bundleContext)
void	setDistPollerDao(DistPollerDao distPollerDao)
void	setMessageDispatcherFactory(MessageDispatcherFactory messageDispatcherFactory)
void	setTelemetryRegistry(TelemetryRegistry telemetryRegistry)
void	updated(String pid, Dictionary<String,?> properties)

Methods inherited from class java.lang.Object

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

Constructor Detail

ListenerManager

public ListenerManager()

Method Detail

getName

public String getName()

Specified by:

getName in interface org.osgi.service.cm.ManagedServiceFactory

updated

public void updated(String pid,
                    Dictionary<String,?> properties)

Specified by:

updated in interface org.osgi.service.cm.ManagedServiceFactory

deleted

public void deleted(String pid)

Specified by:

deleted in interface org.osgi.service.cm.ManagedServiceFactory

init

public void init()

destroy

public void destroy()

getMessageDispatcherFactory

public MessageDispatcherFactory getMessageDispatcherFactory()

setMessageDispatcherFactory

public void setMessageDispatcherFactory(MessageDispatcherFactory messageDispatcherFactory)

getDistPollerDao

public DistPollerDao getDistPollerDao()

setDistPollerDao

public void setDistPollerDao(DistPollerDao distPollerDao)

setBundleContext

public void setBundleContext(org.osgi.framework.BundleContext bundleContext)

setTelemetryRegistry

public void setTelemetryRegistry(TelemetryRegistry telemetryRegistry)