Modifier and Type | Class and Description |
---|---|
class |
MinionGrpcClient
Minion GRPC client runs both RPC/Sink together.
|
Modifier and Type | Class and Description |
---|---|
class |
GrpcLocalDispatcherFactory |
Modifier and Type | Class and Description |
---|---|
class |
OsgiLocalDispatcherFactory |
Modifier and Type | Class and Description |
---|---|
class |
AmazonSQSLocalMessageDispatcherFactory
Dispatches the messages directly the consumers.
|
class |
AmazonSQSRemoteMessageDispatcherFactory
A factory for creating AwsRemoteMessageDispatcher objects.
|
Modifier and Type | Class and Description |
---|---|
class |
CamelLocalMessageDispatcherFactory
Message producer that dispatches the messages directly the consumers.
|
class |
CamelRemoteMessageDispatcherFactory
Message dispatcher that sends messages via JMS.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractMessageDispatcherFactory<W>
This class does all the hard work of building and maintaining the state of the message
dispatchers so that concrete implementations only need to focus on dispatching the messages.
|
Modifier and Type | Class and Description |
---|---|
class |
KafkaLocalMessageDispatcherFactory
Dispatches the messages directly the consumers.
|
class |
KafkaRemoteMessageDispatcherFactory |
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. |
Constructor and Description |
---|
EventDispatcherImpl(MessageDispatcherFactory messageDispatcherFactory,
EventdConfig eventdConfig) |
Constructor and Description |
---|
HeartbeatProducer(MinionIdentity identity,
MessageDispatcherFactory messageDispatcherFactory) |
Modifier and Type | Method and Description |
---|---|
void |
SinkDispatchingSyslogReceiver.setMessageDispatcherFactory(MessageDispatcherFactory messageDispatcherFactory) |
Modifier and Type | Method and Description |
---|---|
MessageDispatcherFactory |
ListenerManager.getMessageDispatcherFactory() |
Modifier and Type | Method and Description |
---|---|
void |
ListenerManager.setMessageDispatcherFactory(MessageDispatcherFactory messageDispatcherFactory) |
Modifier and Type | Method and Description |
---|---|
void |
TrapListener.setMessageDispatcherFactory(MessageDispatcherFactory messageDispatcherFactory) |
Copyright © 2020. All rights reserved.