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.
|
Constructor and Description |
---|
DispatcherState(AbstractMessageDispatcherFactory<W> dispatcherFactory,
SinkModule<S,T> module) |
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. |
Copyright © 2020. All rights reserved.