Package org.opennms.core.ipc.sink.camel.client

Class CamelLocalMessageDispatcherFactory

java.lang.Object

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

org.opennms.core.ipc.sink.camel.client.CamelLocalMessageDispatcherFactory

All Implemented Interfaces:

MessageDispatcherFactory, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean

public class CamelLocalMessageDispatcherFactory
extends AbstractMessageDispatcherFactory<java.lang.Void>
implements org.springframework.beans.factory.InitializingBean, org.springframework.beans.factory.DisposableBean

Message producer that dispatches the messages directly the consumers.

Author:

jwhite

Constructor Summary

Constructors

Constructor	Description
CamelLocalMessageDispatcherFactory()

Method Summary

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

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

CamelLocalMessageDispatcherFactory

public CamelLocalMessageDispatcherFactory()

Method Detail

dispatch

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

Specified by:

dispatch in class AbstractMessageDispatcherFactory<java.lang.Void>

getMetricDomain

public java.lang.String getMetricDomain()

Specified by:

getMetricDomain in class AbstractMessageDispatcherFactory<java.lang.Void>

getBundleContext

public org.osgi.framework.BundleContext getBundleContext()

Specified by:

getBundleContext in class AbstractMessageDispatcherFactory<java.lang.Void>

getTracerRegistry

public TracerRegistry getTracerRegistry()

setTracerRegistry

public void setTracerRegistry(TracerRegistry tracerRegistry)

getTracer

public io.opentracing.Tracer getTracer()

Specified by:

getTracer in class AbstractMessageDispatcherFactory<java.lang.Void>

afterPropertiesSet

public void afterPropertiesSet()

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

destroy

public void destroy()

Specified by:

destroy in interface org.springframework.beans.factory.DisposableBean

getMetrics

public com.codahale.metrics.MetricRegistry getMetrics()

Specified by:

getMetrics in class AbstractMessageDispatcherFactory<java.lang.Void>

setMetrics

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