Uses of Interface
org.opennms.core.ipc.sink.api.SinkModule
-
-
Uses of SinkModule in org.opennms.core.ipc.grpc.client
Methods in org.opennms.core.ipc.grpc.client with parameters of type SinkModule Modifier and Type Method Description <S extends Message,T extends Message>
voidMinionGrpcClient. dispatch(SinkModule<S,T> module, java.lang.String metadata, T message)
-
Uses of SinkModule in org.opennms.core.ipc.grpc.server
Methods in org.opennms.core.ipc.grpc.server with parameters of type SinkModule Modifier and Type Method Description <S extends Message,T extends Message>
voidGrpcLocalDispatcherFactory. dispatch(SinkModule<S,T> module, java.lang.Void metadata, T message)
protected void
OpennmsGrpcServer. startConsumingForModule(SinkModule<?,Message> module)
protected void
OpennmsGrpcServer. stopConsumingForModule(SinkModule<?,Message> module)
-
Uses of SinkModule in org.opennms.core.ipc.osgi
Methods in org.opennms.core.ipc.osgi with parameters of type SinkModule Modifier and Type Method Description <S extends Message,T extends Message>
voidOsgiIpcManager. dispatch(SinkModule<S,T> module, T message)
<S extends Message,T extends Message>
voidOsgiLocalDispatcherFactory. dispatch(SinkModule<S,T> module, java.lang.Void metadata, T message)
protected void
OsgiIpcManager. startConsumingForModule(SinkModule<?,Message> module)
protected void
OsgiIpcManager. stopConsumingForModule(SinkModule<?,Message> module)
-
Uses of SinkModule in org.opennms.core.ipc.sink.aggregation
Constructors in org.opennms.core.ipc.sink.aggregation with parameters of type SinkModule Constructor Description AggregatingSinkMessageProducer(SinkModule<S,T> module)
SinkAggregator(SinkModule<S,T> module, AggregatingSinkMessageProducer<S,T> messageProducer)
-
Uses of SinkModule in org.opennms.core.ipc.sink.api
Methods in org.opennms.core.ipc.sink.api that return SinkModule Modifier and Type Method Description SinkModule<S,T>
MessageConsumer. getModule()
Methods in org.opennms.core.ipc.sink.api with parameters of type SinkModule Modifier and Type Method Description <S extends Message,T extends Message>
AsyncDispatcher<S>MessageDispatcherFactory. createAsyncDispatcher(SinkModule<S,T> module)
Creates a new dispatcher used to send messages asynchronously.<S extends Message,T extends Message>
SyncDispatcher<S>MessageDispatcherFactory. createSyncDispatcher(SinkModule<S,T> module)
Creates a new synchronous dispatcher that will lock the calling thread when dispatching messages.<S extends Message,T extends Message>
voidMessageConsumerManager. dispatch(SinkModule<S,T> module, T message)
-
Uses of SinkModule in org.opennms.core.ipc.sink.aws.sqs.client
Methods in org.opennms.core.ipc.sink.aws.sqs.client with parameters of type SinkModule Modifier and Type Method Description <S extends Message,T extends Message>
voidAmazonSQSLocalMessageDispatcherFactory. dispatch(SinkModule<S,T> module, java.lang.Void metadata, T message)
<S extends Message,T extends Message>
voidAmazonSQSRemoteMessageDispatcherFactory. dispatch(SinkModule<S,T> module, java.lang.String topic, T message)
-
Uses of SinkModule in org.opennms.core.ipc.sink.aws.sqs.server
Methods in org.opennms.core.ipc.sink.aws.sqs.server with parameters of type SinkModule Modifier and Type Method Description protected void
AmazonSQSMessageConsumerManager. startConsumingForModule(SinkModule<?,Message> module)
protected void
AmazonSQSMessageConsumerManager. stopConsumingForModule(SinkModule<?,Message> module)
-
Uses of SinkModule in org.opennms.core.ipc.sink.camel.client
Methods in org.opennms.core.ipc.sink.camel.client with parameters of type SinkModule Modifier and Type Method Description <S extends Message,T extends Message>
voidCamelLocalMessageDispatcherFactory. dispatch(SinkModule<S,T> module, java.lang.Void metadata, T message)
<S extends Message,T extends Message>
voidCamelRemoteMessageDispatcherFactory. dispatch(SinkModule<S,T> module, java.util.Map<java.lang.String,java.lang.Object> headers, T message)
<S extends Message,T extends Message>
java.util.Map<java.lang.String,java.lang.Object>CamelRemoteMessageDispatcherFactory. getModuleMetadata(SinkModule<S,T> module)
-
Uses of SinkModule in org.opennms.core.ipc.sink.camel.server
Methods in org.opennms.core.ipc.sink.camel.server with parameters of type SinkModule Modifier and Type Method Description protected void
CamelMessageConsumerManager. startConsumingForModule(SinkModule<?,Message> module)
protected void
CamelMessageConsumerManager. stopConsumingForModule(SinkModule<?,Message> module)
Constructors in org.opennms.core.ipc.sink.camel.server with parameters of type SinkModule Constructor Description CamelSinkServerProcessor(CamelMessageConsumerManager consumerManager, SinkModule<?,Message> module, TracerRegistry tracerRegistry, com.codahale.metrics.MetricRegistry metricRegistry)
-
Uses of SinkModule in org.opennms.core.ipc.sink.common
Methods in org.opennms.core.ipc.sink.common that return SinkModule Modifier and Type Method Description SinkModule<S,T>
DispatcherState. getModule()
Methods in org.opennms.core.ipc.sink.common with parameters of type SinkModule Modifier and Type Method Description <S extends Message,T extends Message>
AsyncDispatcher<S>AbstractMessageDispatcherFactory. createAsyncDispatcher(SinkModule<S,T> module)
<S extends Message,T extends Message>
SyncDispatcher<S>AbstractMessageDispatcherFactory. createSyncDispatcher(SinkModule<S,T> module)
<S extends Message,T extends Message>
voidAbstractMessageConsumerManager. dispatch(SinkModule<S,T> module, T message)
abstract <S extends Message,T extends Message>
voidAbstractMessageDispatcherFactory. dispatch(SinkModule<S,T> module, W metadata, T message)
<S extends Message,T extends Message>
WAbstractMessageDispatcherFactory. getModuleMetadata(SinkModule<S,T> module)
Optionally build meta-data or state information for the module which will be passed on all the calls toAbstractMessageDispatcherFactory.dispatch(org.opennms.core.ipc.sink.api.SinkModule<S, T>, W, T)
.static int
AbstractMessageConsumerManager. getNumConsumerThreads(SinkModule<?,?> module)
protected abstract void
AbstractMessageConsumerManager. startConsumingForModule(SinkModule<?,Message> module)
protected abstract void
AbstractMessageConsumerManager. stopConsumingForModule(SinkModule<?,Message> module)
Constructors in org.opennms.core.ipc.sink.common with parameters of type SinkModule Constructor Description DispatcherState(AbstractMessageDispatcherFactory<W> dispatcherFactory, SinkModule<S,T> module)
-
Uses of SinkModule in org.opennms.core.ipc.sink.kafka.client
Methods in org.opennms.core.ipc.sink.kafka.client with parameters of type SinkModule Modifier and Type Method Description <S extends Message,T extends Message>
voidKafkaLocalMessageDispatcherFactory. dispatch(SinkModule<S,T> module, java.lang.Void metadata, T message)
<S extends Message,T extends Message>
voidKafkaRemoteMessageDispatcherFactory. dispatch(SinkModule<S,T> module, java.lang.String topic, T message)
<S extends Message,T extends Message>
java.lang.StringKafkaRemoteMessageDispatcherFactory. getModuleMetadata(SinkModule<S,T> module)
-
Uses of SinkModule in org.opennms.core.ipc.sink.kafka.server
Methods in org.opennms.core.ipc.sink.kafka.server with parameters of type SinkModule Modifier and Type Method Description protected void
KafkaMessageConsumerManager. startConsumingForModule(SinkModule<?,Message> module)
protected void
KafkaMessageConsumerManager. stopConsumingForModule(SinkModule<?,Message> module)
-
Uses of SinkModule in org.opennms.core.ipc.sink.mock
Classes in org.opennms.core.ipc.sink.mock that implement SinkModule Modifier and Type Class Description class
MockSinkModule<S extends Message,T extends Message>
Methods in org.opennms.core.ipc.sink.mock with parameters of type SinkModule Modifier and Type Method Description <S extends Message,T extends Message>
voidMockMessageConsumerManager. dispatch(SinkModule<S,T> module, T message)
<S extends Message,T extends Message>
voidMockMessageDispatcherFactory. dispatch(SinkModule<S,T> module, java.lang.Void metadata, T message)
-
Uses of SinkModule in org.opennms.core.ipc.sink.xml
Classes in org.opennms.core.ipc.sink.xml that implement SinkModule Modifier and Type Class Description class
AbstractXmlSinkModule<S extends Message,T extends Message>
-
Uses of SinkModule in org.opennms.features.events.sink.module
Classes in org.opennms.features.events.sink.module that implement SinkModule Modifier and Type Class Description class
EventSinkModule
-
Uses of SinkModule in org.opennms.minion.heartbeat.common
Classes in org.opennms.minion.heartbeat.common that implement SinkModule Modifier and Type Class Description class
HeartbeatModule
-
Uses of SinkModule in org.opennms.minion.heartbeat.consumer
Methods in org.opennms.minion.heartbeat.consumer that return SinkModule Modifier and Type Method Description SinkModule<MinionIdentityDTO,MinionIdentityDTO>
HeartbeatConsumer. getModule()
-
Uses of SinkModule in org.opennms.netmgt.eventd.sink
Methods in org.opennms.netmgt.eventd.sink that return SinkModule Modifier and Type Method Description SinkModule<Event,Log>
EventSinkConsumer. getModule()
-
Uses of SinkModule in org.opennms.netmgt.syslogd
Classes in org.opennms.netmgt.syslogd that implement SinkModule Modifier and Type Class Description class
SyslogSinkModule
-
Uses of SinkModule in org.opennms.netmgt.telemetry.common.ipc
Classes in org.opennms.netmgt.telemetry.common.ipc that implement SinkModule Modifier and Type Class Description class
TelemetrySinkModule
-
Uses of SinkModule in org.opennms.netmgt.telemetry.daemon
Methods in org.opennms.netmgt.telemetry.daemon that return SinkModule Modifier and Type Method Description SinkModule<TelemetryMessage,TelemetryProtos.TelemetryMessageLog>
TelemetryMessageConsumer. getModule()
-
Uses of SinkModule in org.opennms.netmgt.trapd
Classes in org.opennms.netmgt.trapd that implement SinkModule Modifier and Type Class Description class
TrapSinkModule
Methods in org.opennms.netmgt.trapd that return SinkModule Modifier and Type Method Description SinkModule<TrapInformationWrapper,TrapLogDTO>
TrapSinkConsumer. getModule()
-