Package org.opennms.netmgt.telemetry.distributed.sentinel

Class AdapterManager

java.lang.Object

org.opennms.netmgt.telemetry.distributed.sentinel.AdapterManager

All Implemented Interfaces:

TelemetryManager, org.osgi.service.cm.ManagedServiceFactory

public class AdapterManager
extends Object
implements org.osgi.service.cm.ManagedServiceFactory, TelemetryManager

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

Author:

mvrueden

Constructor Summary

Constructors

Constructor	Description
AdapterManager()

Method Summary

Modifier and Type	Method	Description
void	deleted(String pid)
void	destroy()
List<Adapter>	getAdapters()	Get the list of currently configured and enabled adapters.
List<Listener>	getListeners()	Get the list of currently configured and enabled listeners.
String	getName()
void	init()
void	setBundleContext(org.osgi.framework.BundleContext bundleContext)
void	setDistPollerDao(DistPollerDao distPollerDao)
void	setMessageConsumerManager(MessageConsumerManager messageConsumerManager)
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

AdapterManager

public AdapterManager()

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()

setDistPollerDao

public void setDistPollerDao(DistPollerDao distPollerDao)

setTelemetryRegistry

public void setTelemetryRegistry(TelemetryRegistry telemetryRegistry)

setMessageConsumerManager

public void setMessageConsumerManager(MessageConsumerManager messageConsumerManager)

setBundleContext

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

getListeners

public List<Listener> getListeners()

Description copied from interface: TelemetryManager

Get the list of currently configured and enabled listeners.

Specified by:

getListeners in interface TelemetryManager

Returns:

the listeners

getAdapters

public List<Adapter> getAdapters()

Description copied from interface: TelemetryManager

Get the list of currently configured and enabled adapters.

Specified by:

getAdapters in interface TelemetryManager

Returns:

the adapters