org.opennms.core.ipc.osgi

Class OsgiLocalDispatcherFactory

java.lang.Object

org.opennms.core.ipc.sink.common.AbstractMessageDispatcherFactory<Void>

org.opennms.core.ipc.osgi.OsgiLocalDispatcherFactory

All Implemented Interfaces:

MessageDispatcherFactory

public class OsgiLocalDispatcherFactory
extends AbstractMessageDispatcherFactory<Void>

Constructor Summary

Constructors

Constructor and Description
OsgiLocalDispatcherFactory()

Method Summary

Modifier and Type	Method and Description
<S extends Message,T extends Message> void	dispatch(SinkModule<S,T> module, Void metadata, T message)
org.osgi.framework.BundleContext	getBundleContext()
String	getMetricDomain()
com.codahale.metrics.MetricRegistry	getMetrics()
io.opentracing.Tracer	getTracer()
void	setMetrics(com.codahale.metrics.MetricRegistry metrics)

Methods inherited from class org.opennms.core.ipc.sink.common.AbstractMessageDispatcherFactory

createAsyncDispatcher, createSyncDispatcher, createSyncDispatcher, getModuleMetadata, onDestroy, onInit

Methods inherited from class java.lang.Object

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

Constructor Detail

OsgiLocalDispatcherFactory

public OsgiLocalDispatcherFactory()

Method Detail

dispatch

public <S extends Message,T extends Message> void dispatch(SinkModule<S,T> module,
                                                           Void metadata,
                                                           T message)

Specified by:

dispatch in class AbstractMessageDispatcherFactory<Void>

getMetricDomain

public String getMetricDomain()

Specified by:

getMetricDomain in class AbstractMessageDispatcherFactory<Void>

getBundleContext

public org.osgi.framework.BundleContext getBundleContext()

Specified by:

getBundleContext in class AbstractMessageDispatcherFactory<Void>

getTracer

public io.opentracing.Tracer getTracer()

Specified by:

getTracer in class AbstractMessageDispatcherFactory<Void>

getMetrics

public com.codahale.metrics.MetricRegistry getMetrics()

Specified by:

getMetrics in class AbstractMessageDispatcherFactory<Void>

setMetrics

public void setMetrics(com.codahale.metrics.MetricRegistry metrics)