public class CamelRemoteMessageDispatcherFactory extends AbstractMessageDispatcherFactory<Map<String,Object>>
Constructor and Description |
---|
CamelRemoteMessageDispatcherFactory() |
Modifier and Type | Method and Description |
---|---|
<S extends Message,T extends Message> |
dispatch(SinkModule<S,T> module,
Map<String,Object> headers,
T message) |
<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) . |
void |
registerJmxReporter() |
void |
unregisterJmxReporter() |
createAsyncDispatcher, createSyncDispatcher, createSyncDispatcher, getMetrics
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 void registerJmxReporter()
public void unregisterJmxReporter()
Copyright © 2017. All rights reserved.