org.opennms.core.ipc.sink.kafka

Class KafkaRemoteMessageDispatcherFactory

java.lang.Object

org.opennms.core.ipc.sink.common.AbstractMessageDispatcherFactory<String>

org.opennms.core.ipc.sink.kafka.KafkaRemoteMessageDispatcherFactory

All Implemented Interfaces:

MessageDispatcherFactory

public class KafkaRemoteMessageDispatcherFactory
extends AbstractMessageDispatcherFactory<String>

Constructor Summary

Constructors

Constructor and Description
KafkaRemoteMessageDispatcherFactory()

Method Summary

Modifier and Type	Method and Description
void	destroy()
<S extends Message,T extends Message> void	dispatch(SinkModule<S,T> module, String topic, T message)
<S extends Message,T extends Message> String	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).
void	init()
void	setConfigAdmin(org.osgi.service.cm.ConfigurationAdmin configAdmin)

Methods inherited from class org.opennms.core.ipc.sink.common.AbstractMessageDispatcherFactory

createAsyncDispatcher, createSyncDispatcher, createSyncDispatcher, getMetrics

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaRemoteMessageDispatcherFactory

public KafkaRemoteMessageDispatcherFactory()

Method Detail

getModuleMetadata

public <S extends Message,T extends Message> String 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<String>

Returns:

dispatch

public <S extends Message,T extends Message> void dispatch(SinkModule<S,T> module,
                                                           String topic,
                                                           T message)

Specified by:

dispatch in class AbstractMessageDispatcherFactory<String>

init

public void init()
          throws IOException

Throws:

IOException

destroy

public void destroy()

setConfigAdmin

public void setConfigAdmin(org.osgi.service.cm.ConfigurationAdmin configAdmin)