Modifier and Type | Method and Description |
---|---|
<S extends Message,T extends Message> |
MinionGrpcClient.dispatch(SinkModule<S,T> module,
String metadata,
T message) |
<S extends Message,T extends Message> |
MinionGrpcClient.dispatch(SinkModule<S,T> module,
String metadata,
T message) |
Modifier and Type | Method and Description |
---|---|
<S extends Message,T extends Message> |
GrpcLocalDispatcherFactory.dispatch(SinkModule<S,T> module,
Void metadata,
T message) |
<S extends Message,T extends Message> |
GrpcLocalDispatcherFactory.dispatch(SinkModule<S,T> module,
Void metadata,
T message) |
Modifier and Type | Method and Description |
---|---|
protected void |
OpennmsGrpcServer.startConsumingForModule(SinkModule<?,Message> module) |
protected void |
OpennmsGrpcServer.stopConsumingForModule(SinkModule<?,Message> module) |
Modifier and Type | Method and Description |
---|---|
<S extends Message,T extends Message> |
OsgiIpcManager.dispatch(SinkModule<S,T> module,
T message) |
<S extends Message,T extends Message> |
OsgiIpcManager.dispatch(SinkModule<S,T> module,
T message) |
<S extends Message,T extends Message> |
OsgiLocalDispatcherFactory.dispatch(SinkModule<S,T> module,
Void metadata,
T message) |
<S extends Message,T extends Message> |
OsgiLocalDispatcherFactory.dispatch(SinkModule<S,T> module,
Void metadata,
T message) |
<S extends Message,T extends Message> |
OsgiIpcManager.registerConsumer(MessageConsumer<S,T> consumer) |
<S extends Message,T extends Message> |
OsgiIpcManager.registerConsumer(MessageConsumer<S,T> consumer) |
<S extends Message,T extends Message> |
OsgiIpcManager.unregisterConsumer(MessageConsumer<S,T> consumer) |
<S extends Message,T extends Message> |
OsgiIpcManager.unregisterConsumer(MessageConsumer<S,T> consumer) |
Modifier and Type | Method and Description |
---|---|
protected void |
OsgiIpcManager.startConsumingForModule(SinkModule<?,Message> module) |
protected void |
OsgiIpcManager.stopConsumingForModule(SinkModule<?,Message> module) |
Modifier and Type | Class and 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
the
Message marker interface. |
class |
SinkAggregator<S extends Message,T extends Message>
This is a specific aggregator where the messsages implement
the
Message marker interface. |
Modifier and Type | Interface and Description |
---|---|
interface |
AsyncDispatcher<S extends Message>
Used to asynchronously dispatch messages.
|
interface |
MessageConsumer<S extends Message,T extends Message>
Implemented by consumers of a particular
SinkModule . |
interface |
MessageConsumer<S extends Message,T extends Message>
Implemented by consumers of a particular
SinkModule . |
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.
|
Modifier and Type | Method and Description |
---|---|
<S extends Message,T extends Message> |
MessageDispatcherFactory.createAsyncDispatcher(SinkModule<S,T> module)
Creates a new dispatcher used to send messages asynchronously.
|
<S extends Message,T extends Message> |
MessageDispatcherFactory.createAsyncDispatcher(SinkModule<S,T> module)
Creates a new dispatcher used to send messages asynchronously.
|
<S extends Message,T extends Message> |
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> |
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> |
MessageConsumerManager.dispatch(SinkModule<S,T> module,
T message) |
<S extends Message,T extends Message> |
MessageConsumerManager.dispatch(SinkModule<S,T> module,
T message) |
<S extends Message,T extends Message> |
MessageConsumerManager.registerConsumer(MessageConsumer<S,T> consumer) |
<S extends Message,T extends Message> |
MessageConsumerManager.registerConsumer(MessageConsumer<S,T> consumer) |
<S extends Message,T extends Message> |
MessageConsumerManager.unregisterConsumer(MessageConsumer<S,T> consumer) |
<S extends Message,T extends Message> |
MessageConsumerManager.unregisterConsumer(MessageConsumer<S,T> consumer) |
Modifier and Type | Method and Description |
---|---|
<S extends Message,T extends Message> |
AmazonSQSRemoteMessageDispatcherFactory.dispatch(SinkModule<S,T> module,
String topic,
T message) |
<S extends Message,T extends Message> |
AmazonSQSRemoteMessageDispatcherFactory.dispatch(SinkModule<S,T> module,
String topic,
T message) |
<S extends Message,T extends Message> |
AmazonSQSLocalMessageDispatcherFactory.dispatch(SinkModule<S,T> module,
Void metadata,
T message) |
<S extends Message,T extends Message> |
AmazonSQSLocalMessageDispatcherFactory.dispatch(SinkModule<S,T> module,
Void metadata,
T message) |
Modifier and Type | Method and Description |
---|---|
protected void |
AmazonSQSMessageConsumerManager.startConsumingForModule(SinkModule<?,Message> module) |
protected void |
AmazonSQSMessageConsumerManager.stopConsumingForModule(SinkModule<?,Message> module) |
Modifier and Type | Method and Description |
---|---|
<S extends Message,T extends Message> |
CamelRemoteMessageDispatcherFactory.dispatch(SinkModule<S,T> module,
Map<String,Object> headers,
T message) |
<S extends Message,T extends Message> |
CamelRemoteMessageDispatcherFactory.dispatch(SinkModule<S,T> module,
Map<String,Object> headers,
T message) |
<S extends Message,T extends Message> |
CamelLocalMessageDispatcherFactory.dispatch(SinkModule<S,T> module,
Void metadata,
T message) |
<S extends Message,T extends Message> |
CamelLocalMessageDispatcherFactory.dispatch(SinkModule<S,T> module,
Void metadata,
T message) |
<S extends Message,T extends Message> |
CamelRemoteMessageDispatcherFactory.getModuleMetadata(SinkModule<S,T> module) |
<S extends Message,T extends Message> |
CamelRemoteMessageDispatcherFactory.getModuleMetadata(SinkModule<S,T> module) |
Modifier and Type | Method and Description |
---|---|
protected void |
CamelMessageConsumerManager.startConsumingForModule(SinkModule<?,Message> module) |
protected void |
CamelMessageConsumerManager.stopConsumingForModule(SinkModule<?,Message> module) |
Constructor and Description |
---|
CamelSinkServerProcessor(CamelMessageConsumerManager consumerManager,
SinkModule<?,Message> module,
TracerRegistry tracerRegistry,
com.codahale.metrics.MetricRegistry metricRegistry) |
Modifier and Type | Class and 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.
|
Modifier and Type | Method and Description |
---|---|
<S extends Message,T extends Message> |
AbstractMessageDispatcherFactory.createAsyncDispatcher(SinkModule<S,T> module) |
<S extends Message,T extends Message> |
AbstractMessageDispatcherFactory.createAsyncDispatcher(SinkModule<S,T> module) |
protected <S extends Message,T extends Message> |
AbstractMessageDispatcherFactory.createSyncDispatcher(DispatcherState<W,S,T> state) |
protected <S extends Message,T extends Message> |
AbstractMessageDispatcherFactory.createSyncDispatcher(DispatcherState<W,S,T> state) |
<S extends Message,T extends Message> |
AbstractMessageDispatcherFactory.createSyncDispatcher(SinkModule<S,T> module) |
<S extends Message,T extends Message> |
AbstractMessageDispatcherFactory.createSyncDispatcher(SinkModule<S,T> module) |
<S extends Message,T extends Message> |
AbstractMessageConsumerManager.dispatch(SinkModule<S,T> module,
T message) |
<S extends Message,T extends Message> |
AbstractMessageConsumerManager.dispatch(SinkModule<S,T> module,
T message) |
abstract <S extends Message,T extends Message> |
AbstractMessageDispatcherFactory.dispatch(SinkModule<S,T> module,
W metadata,
T message) |
abstract <S extends Message,T extends Message> |
AbstractMessageDispatcherFactory.dispatch(SinkModule<S,T> module,
W metadata,
T message) |
<S extends Message,T extends Message> |
AbstractMessageDispatcherFactory.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) . |
<S extends Message,T extends Message> |
AbstractMessageDispatcherFactory.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) . |
<S extends Message,T extends Message> |
AbstractMessageConsumerManager.registerConsumer(MessageConsumer<S,T> consumer) |
<S extends Message,T extends Message> |
AbstractMessageConsumerManager.registerConsumer(MessageConsumer<S,T> consumer) |
<S extends Message,T extends Message> |
AbstractMessageConsumerManager.unregisterConsumer(MessageConsumer<S,T> consumer) |
<S extends Message,T extends Message> |
AbstractMessageConsumerManager.unregisterConsumer(MessageConsumer<S,T> consumer) |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
AbstractMessageConsumerManager.startConsumingForModule(SinkModule<?,Message> module) |
protected abstract void |
AbstractMessageConsumerManager.stopConsumingForModule(SinkModule<?,Message> module) |
Modifier and Type | Method and Description |
---|---|
<S extends Message,T extends Message> |
KafkaRemoteMessageDispatcherFactory.dispatch(SinkModule<S,T> module,
String topic,
T message) |
<S extends Message,T extends Message> |
KafkaRemoteMessageDispatcherFactory.dispatch(SinkModule<S,T> module,
String topic,
T message) |
<S extends Message,T extends Message> |
KafkaLocalMessageDispatcherFactory.dispatch(SinkModule<S,T> module,
Void metadata,
T message) |
<S extends Message,T extends Message> |
KafkaLocalMessageDispatcherFactory.dispatch(SinkModule<S,T> module,
Void metadata,
T message) |
<S extends Message,T extends Message> |
KafkaRemoteMessageDispatcherFactory.getModuleMetadata(SinkModule<S,T> module) |
<S extends Message,T extends Message> |
KafkaRemoteMessageDispatcherFactory.getModuleMetadata(SinkModule<S,T> module) |
Modifier and Type | Method and Description |
---|---|
protected void |
KafkaMessageConsumerManager.startConsumingForModule(SinkModule<?,Message> module) |
protected void |
KafkaMessageConsumerManager.stopConsumingForModule(SinkModule<?,Message> module) |
Modifier and Type | Class and Description |
---|---|
class |
KafkaOffset |
Modifier and Type | Class and Description |
---|---|
class |
MockMessageDispatcherFactory<U extends Message,V extends Message>
A simple
MessageDispatcherFactory that handles all messages with a single consumer. |
class |
MockMessageDispatcherFactory<U extends Message,V extends Message>
A simple
MessageDispatcherFactory that handles all messages with a single consumer. |
class |
MockSinkModule<S extends Message,T extends Message> |
class |
MockSinkModule<S extends Message,T extends Message> |
Modifier and Type | Method and Description |
---|---|
<S extends Message,T extends Message> |
MockMessageConsumerManager.dispatch(SinkModule<S,T> module,
T message) |
<S extends Message,T extends Message> |
MockMessageConsumerManager.dispatch(SinkModule<S,T> module,
T message) |
<S extends Message,T extends Message> |
MockMessageDispatcherFactory.dispatch(SinkModule<S,T> module,
Void metadata,
T message) |
<S extends Message,T extends Message> |
MockMessageDispatcherFactory.dispatch(SinkModule<S,T> module,
Void metadata,
T message) |
<S extends Message,T extends Message> |
MockMessageConsumerManager.registerConsumer(MessageConsumer<S,T> consumer) |
<S extends Message,T extends Message> |
MockMessageConsumerManager.registerConsumer(MessageConsumer<S,T> consumer) |
<S extends Message,T extends Message> |
MockMessageConsumerManager.unregisterConsumer(MessageConsumer<S,T> consumer) |
<S extends Message,T extends Message> |
MockMessageConsumerManager.unregisterConsumer(MessageConsumer<S,T> consumer) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractXmlSinkModule<S extends Message,T extends Message> |
class |
AbstractXmlSinkModule<S extends Message,T extends Message> |
Modifier and Type | Class and Description |
---|---|
class |
MinionIdentityDTO |
Modifier and Type | Class and Description |
---|---|
class |
SyslogConnection |
class |
SyslogMessageLogDTO |
Modifier and Type | Interface and Description |
---|---|
interface |
TelemetryMessageLogEntry |
Modifier and Type | Class and Description |
---|---|
class |
TelemetryMessage |
Modifier and Type | Class and Description |
---|---|
static class |
TelemetryProtos.TelemetryMessage
Protobuf type
TelemetryMessage |
Modifier and Type | Class and Description |
---|---|
class |
TrapDTO |
class |
TrapInformationWrapper
Wrapper to make the
TrapInformation object Sink API compatible, without adding the dependency to the sink-api module. |
class |
TrapLogDTO |
Modifier and Type | Class and Description |
---|---|
class |
Event |
class |
Log
Class Log.
|
Copyright © 2020. All rights reserved.