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

Class CamelRemoteMessageDispatcherFactory

java.lang.Object

org.opennms.core.ipc.sink.common.AbstractMessageDispatcherFactory<java.util.Map<java.lang.String,java.lang.Object>>

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

All Implemented Interfaces:

MessageDispatcherFactory

public class CamelRemoteMessageDispatcherFactory
extends AbstractMessageDispatcherFactory<java.util.Map<java.lang.String,java.lang.Object>>

Message dispatcher that sends messages via JMS.

Author:

jwhite

Constructor Summary

Constructors

Constructor	Description
CamelRemoteMessageDispatcherFactory()

Method Summary

Modifier and Type	Method	Description
void	destroy()
<S extends Message,T extends Message> void	dispatch(SinkModule<S,T> module, java.util.Map<java.lang.String,java.lang.Object> headers, T message)
org.osgi.framework.BundleContext	getBundleContext()
Identity	getIdentity()
java.lang.String	getMetricDomain()
com.codahale.metrics.MetricRegistry	getMetrics()
<S extends Message,T extends Message> java.util.Map<java.lang.String,java.lang.Object>	getModuleMetadata(SinkModule<S,T> module)	Optionally build meta-data or state information for the module which will be passed on all the calls to AbstractMessageDispatcherFactory.dispatch(org.opennms.core.ipc.sink.api.SinkModule<S, T>, W, T).
io.opentracing.Tracer	getTracer()
TracerRegistry	getTracerRegistry()
void	init()
void	setBundleContext(org.osgi.framework.BundleContext bundleContext)
void	setIdentity(Identity identity)
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, onDestroy, onInit

Methods inherited from class java.lang.Object

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

Constructor Detail

CamelRemoteMessageDispatcherFactory

public CamelRemoteMessageDispatcherFactory()

Method Detail

getModuleMetadata

public <S extends Message,T extends Message> java.util.Map<java.lang.String,java.lang.Object> getModuleMetadata(SinkModule<S,T> module)

Description copied from class: AbstractMessageDispatcherFactory

Optionally build meta-data or state information for the module which will be passed on all the calls to AbstractMessageDispatcherFactory.dispatch(org.opennms.core.ipc.sink.api.SinkModule<S, T>, W, T). This is useful for calculating things like message headers which are re-used on every dispatch.

Overrides:

getModuleMetadata in class AbstractMessageDispatcherFactory<java.util.Map<java.lang.String,java.lang.Object>>

Returns:

dispatch

public <S extends Message,T extends Message> void dispatch(SinkModule<S,T> module,
                                                                 java.util.Map<java.lang.String,java.lang.Object> headers,
                                                                 T message)

Specified by:

dispatch in class AbstractMessageDispatcherFactory<java.util.Map<java.lang.String,java.lang.Object>>

getMetricDomain

public java.lang.String getMetricDomain()

Specified by:

getMetricDomain in class AbstractMessageDispatcherFactory<java.util.Map<java.lang.String,java.lang.Object>>

getBundleContext

public org.osgi.framework.BundleContext getBundleContext()

Specified by:

getBundleContext in class AbstractMessageDispatcherFactory<java.util.Map<java.lang.String,java.lang.Object>>

init

public void init()

destroy

public void destroy()

setBundleContext

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

getTracerRegistry

public TracerRegistry getTracerRegistry()

getTracer

public io.opentracing.Tracer getTracer()

Specified by:

getTracer in class AbstractMessageDispatcherFactory<java.util.Map<java.lang.String,java.lang.Object>>

getMetrics

public com.codahale.metrics.MetricRegistry getMetrics()

Specified by:

getMetrics in class AbstractMessageDispatcherFactory<java.util.Map<java.lang.String,java.lang.Object>>

setMetrics

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

setTracerRegistry

public void setTracerRegistry(TracerRegistry tracerRegistry)

getIdentity

public Identity getIdentity()

setIdentity

public void setIdentity(Identity identity)