public class CamelRemoteMessageDispatcherFactory extends AbstractMessageDispatcherFactory<Map<String,Object>>
Constructor and Description |
---|
CamelRemoteMessageDispatcherFactory() |
Modifier and Type | Method and Description |
---|---|
void |
destroy() |
<S extends Message,T extends Message> |
dispatch(SinkModule<S,T> module,
Map<String,Object> headers,
T message) |
org.osgi.framework.BundleContext |
getBundleContext() |
Identity |
getIdentity() |
String |
getMetricDomain() |
com.codahale.metrics.MetricRegistry |
getMetrics() |
<S extends Message,T extends Message> |
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) |
createAsyncDispatcher, createSyncDispatcher, createSyncDispatcher, onDestroy, onInit
public <S extends Message,T extends Message> Map<String,Object> getModuleMetadata(SinkModule<S,T> module)
AbstractMessageDispatcherFactory
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.getModuleMetadata
in class AbstractMessageDispatcherFactory<Map<String,Object>>
public <S extends Message,T extends Message> void dispatch(SinkModule<S,T> module, Map<String,Object> headers, T message)
dispatch
in class AbstractMessageDispatcherFactory<Map<String,Object>>
public String getMetricDomain()
getMetricDomain
in class AbstractMessageDispatcherFactory<Map<String,Object>>
public org.osgi.framework.BundleContext getBundleContext()
getBundleContext
in class AbstractMessageDispatcherFactory<Map<String,Object>>
public void init()
public void destroy()
public void setBundleContext(org.osgi.framework.BundleContext bundleContext)
public TracerRegistry getTracerRegistry()
public io.opentracing.Tracer getTracer()
getTracer
in class AbstractMessageDispatcherFactory<Map<String,Object>>
public com.codahale.metrics.MetricRegistry getMetrics()
getMetrics
in class AbstractMessageDispatcherFactory<Map<String,Object>>
public void setMetrics(com.codahale.metrics.MetricRegistry metrics)
public void setTracerRegistry(TracerRegistry tracerRegistry)
public Identity getIdentity()
public void setIdentity(Identity identity)
Copyright © 2020. All rights reserved.