public class KafkaRemoteMessageDispatcherFactory extends AbstractMessageDispatcherFactory<String>
Constructor and Description |
---|
KafkaRemoteMessageDispatcherFactory() |
Modifier and Type | Method and Description |
---|---|
void |
destroy() |
<S extends Message,T extends Message> |
dispatch(SinkModule<S,T> module,
String topic,
T message) |
org.osgi.framework.BundleContext |
getBundleContext() |
Identity |
getIdentity() |
Integer |
getMaxBufferSize() |
String |
getMetricDomain() |
<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 |
setConfigAdmin(org.osgi.service.cm.ConfigurationAdmin configAdmin) |
void |
setIdentity(Identity identity) |
void |
setTracerRegistry(TracerRegistry tracerRegistry) |
createAsyncDispatcher, createSyncDispatcher, createSyncDispatcher, getMetrics, onDestroy, onInit
public <S extends Message,T extends Message> String 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<String>
public <S extends Message,T extends Message> void dispatch(SinkModule<S,T> module, String topic, T message)
dispatch
in class AbstractMessageDispatcherFactory<String>
public void init() throws IOException
IOException
public void destroy()
public String getMetricDomain()
getMetricDomain
in class AbstractMessageDispatcherFactory<String>
public org.osgi.framework.BundleContext getBundleContext()
getBundleContext
in class AbstractMessageDispatcherFactory<String>
public void setConfigAdmin(org.osgi.service.cm.ConfigurationAdmin configAdmin)
public void setBundleContext(org.osgi.framework.BundleContext bundleContext)
public Integer getMaxBufferSize()
public void setTracerRegistry(TracerRegistry tracerRegistry)
public TracerRegistry getTracerRegistry()
public io.opentracing.Tracer getTracer()
getTracer
in class AbstractMessageDispatcherFactory<String>
public Identity getIdentity()
public void setIdentity(Identity identity)
Copyright © 2020. All rights reserved.