Uses of Interface
org.opennms.core.ipc.sink.api.Message
-
-
Uses of Message in org.opennms.core.ipc.grpc.client
Methods in org.opennms.core.ipc.grpc.client with type parameters of type Message Modifier and Type Method Description <S extends Message,T extends Message>
voidMinionGrpcClient. dispatch(SinkModule<S,T> module, java.lang.String metadata, T message)
<S extends Message,T extends Message>
voidMinionGrpcClient. dispatch(SinkModule<S,T> module, java.lang.String metadata, T message)
-
Uses of Message in org.opennms.core.ipc.grpc.server
Methods in org.opennms.core.ipc.grpc.server with type parameters of type Message Modifier and Type Method Description <S extends Message,T extends Message>
voidGrpcLocalDispatcherFactory. dispatch(SinkModule<S,T> module, java.lang.Void metadata, T message)
<S extends Message,T extends Message>
voidGrpcLocalDispatcherFactory. dispatch(SinkModule<S,T> module, java.lang.Void metadata, T message)
Method parameters in org.opennms.core.ipc.grpc.server with type arguments of type Message Modifier and Type Method Description protected void
OpennmsGrpcServer. startConsumingForModule(SinkModule<?,Message> module)
protected void
OpennmsGrpcServer. stopConsumingForModule(SinkModule<?,Message> module)
-
Uses of Message in org.opennms.core.ipc.osgi
Methods in org.opennms.core.ipc.osgi with type parameters of type Message 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>
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)
<S extends Message,T extends Message>
voidOsgiLocalDispatcherFactory. dispatch(SinkModule<S,T> module, java.lang.Void metadata, T message)
<S extends Message,T extends Message>
voidOsgiIpcManager. registerConsumer(MessageConsumer<S,T> consumer)
<S extends Message,T extends Message>
voidOsgiIpcManager. registerConsumer(MessageConsumer<S,T> consumer)
<S extends Message,T extends Message>
voidOsgiIpcManager. unregisterConsumer(MessageConsumer<S,T> consumer)
<S extends Message,T extends Message>
voidOsgiIpcManager. unregisterConsumer(MessageConsumer<S,T> consumer)
Method parameters in org.opennms.core.ipc.osgi with type arguments of type Message Modifier and Type Method Description protected void
OsgiIpcManager. startConsumingForModule(SinkModule<?,Message> module)
protected void
OsgiIpcManager. stopConsumingForModule(SinkModule<?,Message> module)
-
Uses of Message in org.opennms.core.ipc.sink.aggregation
Classes in org.opennms.core.ipc.sink.aggregation with type parameters of type Message Modifier and Type Class Description class
AggregatingSinkMessageProducer<S extends Message,T extends Message>
class
AggregatingSinkMessageProducer<S extends Message,T extends Message>
class
IdentityAggregationPolicy<T extends Message>
An aggregation policy that returns the original unmodified message as the aggregate.class
MappingAggregationPolicy<S,T extends Message>
An aggregation policy that performs a simple map operation on the given message.class
SinkAggregator<S extends Message,T extends Message>
This is a specific aggregator where the messsages implement theMessage
marker interface.class
SinkAggregator<S extends Message,T extends Message>
This is a specific aggregator where the messsages implement theMessage
marker interface. -
Uses of Message in org.opennms.core.ipc.sink.api
Classes in org.opennms.core.ipc.sink.api with type parameters of type Message Modifier and Type Interface Description interface
AsyncDispatcher<S extends Message>
Used to asynchronously dispatch messages.interface
MessageConsumer<S extends Message,T extends Message>
Implemented by consumers of a particularSinkModule
.interface
MessageConsumer<S extends Message,T extends Message>
Implemented by consumers of a particularSinkModule
.interface
SinkModule<S extends Message,T extends Message>
Defines how the messages will be routed and marshaled/unmarshaled over the wire.interface
SinkModule<S extends Message,T extends Message>
Defines how the messages will be routed and marshaled/unmarshaled over the wire.interface
SyncDispatcher<S extends Message>
Used to synchronously dispatch messages.Methods in org.opennms.core.ipc.sink.api with type parameters of type Message 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>
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>
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)
<S extends Message,T extends Message>
voidMessageConsumerManager. dispatch(SinkModule<S,T> module, T message)
<S extends Message,T extends Message>
voidMessageConsumerManager. registerConsumer(MessageConsumer<S,T> consumer)
<S extends Message,T extends Message>
voidMessageConsumerManager. registerConsumer(MessageConsumer<S,T> consumer)
<S extends Message,T extends Message>
voidMessageConsumerManager. unregisterConsumer(MessageConsumer<S,T> consumer)
<S extends Message,T extends Message>
voidMessageConsumerManager. unregisterConsumer(MessageConsumer<S,T> consumer)
-
Uses of Message in org.opennms.core.ipc.sink.aws.sqs.client
Methods in org.opennms.core.ipc.sink.aws.sqs.client with type parameters of type Message 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>
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)
<S extends Message,T extends Message>
voidAmazonSQSRemoteMessageDispatcherFactory. dispatch(SinkModule<S,T> module, java.lang.String topic, T message)
-
Uses of Message in org.opennms.core.ipc.sink.aws.sqs.server
Method parameters in org.opennms.core.ipc.sink.aws.sqs.server with type arguments of type Message Modifier and Type Method Description protected void
AmazonSQSMessageConsumerManager. startConsumingForModule(SinkModule<?,Message> module)
protected void
AmazonSQSMessageConsumerManager. stopConsumingForModule(SinkModule<?,Message> module)
-
Uses of Message in org.opennms.core.ipc.sink.camel.client
Methods in org.opennms.core.ipc.sink.camel.client with type parameters of type Message 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>
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>
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)
<S extends Message,T extends Message>
java.util.Map<java.lang.String,java.lang.Object>CamelRemoteMessageDispatcherFactory. getModuleMetadata(SinkModule<S,T> module)
-
Uses of Message in org.opennms.core.ipc.sink.camel.server
Method parameters in org.opennms.core.ipc.sink.camel.server with type arguments of type Message Modifier and Type Method Description protected void
CamelMessageConsumerManager. startConsumingForModule(SinkModule<?,Message> module)
protected void
CamelMessageConsumerManager. stopConsumingForModule(SinkModule<?,Message> module)
Constructor parameters in org.opennms.core.ipc.sink.camel.server with type arguments of type Message Constructor Description CamelSinkServerProcessor(CamelMessageConsumerManager consumerManager, SinkModule<?,Message> module, TracerRegistry tracerRegistry, com.codahale.metrics.MetricRegistry metricRegistry)
-
Uses of Message in org.opennms.core.ipc.sink.common
Classes in org.opennms.core.ipc.sink.common with type parameters of type Message Modifier and Type Class Description class
AsyncDispatcherImpl<W,S extends Message,T extends Message>
class
AsyncDispatcherImpl<W,S extends Message,T extends Message>
class
DispatcherState<W,S extends Message,T extends Message>
The state and metrics pertaining to a particular dispatches.class
DispatcherState<W,S extends Message,T extends Message>
The state and metrics pertaining to a particular dispatches.Methods in org.opennms.core.ipc.sink.common with type parameters of type Message 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>
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>
SyncDispatcher<S>AbstractMessageDispatcherFactory. createSyncDispatcher(SinkModule<S,T> module)
protected <S extends Message,T extends Message>
SyncDispatcher<S>AbstractMessageDispatcherFactory. createSyncDispatcher(DispatcherState<W,S,T> state)
protected <S extends Message,T extends Message>
SyncDispatcher<S>AbstractMessageDispatcherFactory. createSyncDispatcher(DispatcherState<W,S,T> state)
<S extends Message,T extends Message>
voidAbstractMessageConsumerManager. dispatch(SinkModule<S,T> module, T message)
<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)
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)
.<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)
.<S extends Message,T extends Message>
voidAbstractMessageConsumerManager. registerConsumer(MessageConsumer<S,T> consumer)
<S extends Message,T extends Message>
voidAbstractMessageConsumerManager. registerConsumer(MessageConsumer<S,T> consumer)
<S extends Message,T extends Message>
voidAbstractMessageConsumerManager. unregisterConsumer(MessageConsumer<S,T> consumer)
<S extends Message,T extends Message>
voidAbstractMessageConsumerManager. unregisterConsumer(MessageConsumer<S,T> consumer)
Method parameters in org.opennms.core.ipc.sink.common with type arguments of type Message Modifier and Type Method Description protected abstract void
AbstractMessageConsumerManager. startConsumingForModule(SinkModule<?,Message> module)
protected abstract void
AbstractMessageConsumerManager. stopConsumingForModule(SinkModule<?,Message> module)
-
Uses of Message in org.opennms.core.ipc.sink.kafka.client
Methods in org.opennms.core.ipc.sink.kafka.client with type parameters of type Message 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>
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>
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)
<S extends Message,T extends Message>
java.lang.StringKafkaRemoteMessageDispatcherFactory. getModuleMetadata(SinkModule<S,T> module)
-
Uses of Message in org.opennms.core.ipc.sink.kafka.server
Method parameters in org.opennms.core.ipc.sink.kafka.server with type arguments of type Message Modifier and Type Method Description protected void
KafkaMessageConsumerManager. startConsumingForModule(SinkModule<?,Message> module)
protected void
KafkaMessageConsumerManager. stopConsumingForModule(SinkModule<?,Message> module)
-
Uses of Message in org.opennms.core.ipc.sink.kafka.server.offset
Classes in org.opennms.core.ipc.sink.kafka.server.offset that implement Message Modifier and Type Class Description class
KafkaOffset
-
Uses of Message in org.opennms.core.ipc.sink.mock
Classes in org.opennms.core.ipc.sink.mock with type parameters of type Message Modifier and Type Class Description class
MockMessageDispatcherFactory<U extends Message,V extends Message>
A simpleMessageDispatcherFactory
that handles all messages with a single consumer.class
MockMessageDispatcherFactory<U extends Message,V extends Message>
A simpleMessageDispatcherFactory
that handles all messages with a single consumer.class
MockSinkModule<S extends Message,T extends Message>
class
MockSinkModule<S extends Message,T extends Message>
Methods in org.opennms.core.ipc.sink.mock with type parameters of type Message 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>
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)
<S extends Message,T extends Message>
voidMockMessageDispatcherFactory. dispatch(SinkModule<S,T> module, java.lang.Void metadata, T message)
<S extends Message,T extends Message>
voidMockMessageConsumerManager. registerConsumer(MessageConsumer<S,T> consumer)
<S extends Message,T extends Message>
voidMockMessageConsumerManager. registerConsumer(MessageConsumer<S,T> consumer)
<S extends Message,T extends Message>
voidMockMessageConsumerManager. unregisterConsumer(MessageConsumer<S,T> consumer)
<S extends Message,T extends Message>
voidMockMessageConsumerManager. unregisterConsumer(MessageConsumer<S,T> consumer)
-
Uses of Message in org.opennms.core.ipc.sink.xml
Classes in org.opennms.core.ipc.sink.xml with type parameters of type Message Modifier and Type Class Description class
AbstractXmlSinkModule<S extends Message,T extends Message>
class
AbstractXmlSinkModule<S extends Message,T extends Message>
-
Uses of Message in org.opennms.minion.heartbeat.common
Classes in org.opennms.minion.heartbeat.common that implement Message Modifier and Type Class Description class
MinionIdentityDTO
-
Uses of Message in org.opennms.netmgt.syslogd.api
Classes in org.opennms.netmgt.syslogd.api that implement Message Modifier and Type Class Description class
SyslogConnection
class
SyslogMessageLogDTO
-
Uses of Message in org.opennms.netmgt.telemetry.api.adapter
Subinterfaces of Message in org.opennms.netmgt.telemetry.api.adapter Modifier and Type Interface Description interface
TelemetryMessageLogEntry
-
Uses of Message in org.opennms.netmgt.telemetry.api.receiver
Classes in org.opennms.netmgt.telemetry.api.receiver that implement Message Modifier and Type Class Description class
TelemetryMessage
-
Uses of Message in org.opennms.netmgt.telemetry.common.ipc
Classes in org.opennms.netmgt.telemetry.common.ipc that implement Message Modifier and Type Class Description static class
TelemetryProtos.TelemetryMessage
Protobuf typeTelemetryMessage
static class
TelemetryProtos.TelemetryMessageLog
Protobuf typeTelemetryMessageLog
-
Uses of Message in org.opennms.netmgt.trapd
Classes in org.opennms.netmgt.trapd that implement Message Modifier and Type Class Description class
TrapDTO
class
TrapInformationWrapper
Wrapper to make theTrapInformation
object Sink API compatible, without adding the dependency to the sink-api module.class
TrapLogDTO
-
Uses of Message in org.opennms.netmgt.xml.event
Classes in org.opennms.netmgt.xml.event that implement Message Modifier and Type Class Description class
Event
class
Log
Class Log.
-