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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
destroy()
<S extends Message,T extends Message>
voiddispatch(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 toAbstractMessageDispatcherFactory.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
-
-
-
-
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 toAbstractMessageDispatcherFactory.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 classAbstractMessageDispatcherFactory<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 classAbstractMessageDispatcherFactory<java.util.Map<java.lang.String,java.lang.Object>>
-
getMetricDomain
public java.lang.String getMetricDomain()
- Specified by:
getMetricDomain
in classAbstractMessageDispatcherFactory<java.util.Map<java.lang.String,java.lang.Object>>
-
getBundleContext
public org.osgi.framework.BundleContext getBundleContext()
- Specified by:
getBundleContext
in classAbstractMessageDispatcherFactory<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 classAbstractMessageDispatcherFactory<java.util.Map<java.lang.String,java.lang.Object>>
-
getMetrics
public com.codahale.metrics.MetricRegistry getMetrics()
- Specified by:
getMetrics
in classAbstractMessageDispatcherFactory<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)
-
-