org.opennms.core.ipc.sink.camel

Class CamelRemoteMessageDispatcherFactory

java.lang.Object

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

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

All Implemented Interfaces:

MessageDispatcherFactory

public class CamelRemoteMessageDispatcherFactory
extends AbstractMessageDispatcherFactory<Map<String,Object>>

Message dispatcher that sends messages via JMS.

Author:

jwhite

Constructor Summary

Constructors

Constructor and Description
CamelRemoteMessageDispatcherFactory()

Method Summary

Modifier and Type	Method and Description
<S extends Message,T extends Message> void	dispatch(SinkModule<S,T> module, Map<String,Object> headers, T message)
<S extends Message,T extends Message> Map<String,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).
void	registerJmxReporter()
void	unregisterJmxReporter()

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

CamelRemoteMessageDispatcherFactory

public CamelRemoteMessageDispatcherFactory()

Method Detail

getModuleMetadata

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

Returns:

dispatch

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

Specified by:

dispatch in class AbstractMessageDispatcherFactory<Map<String,Object>>

registerJmxReporter

public void registerJmxReporter()

unregisterJmxReporter

public void unregisterJmxReporter()