Modifier and Type | Method and Description |
---|---|
<S extends RpcRequest,T extends RpcResponse> |
KafkaRpcClientFactory.getClient(RpcModule<S,T> module) |
Modifier and Type | Method and Description |
---|---|
protected void |
KafkaRpcServerManager.startConsumerForModule(RpcModule<RpcRequest,RpcResponse> rpcModule) |
protected void |
KafkaRpcServerManager.stopConsumerForModule(RpcModule<RpcRequest,RpcResponse> rpcModule) |
Modifier and Type | Interface and Description |
---|---|
interface |
RpcClient<S extends RpcRequest,T extends RpcResponse>
Asynchronously executes remote procedure calls (RPCs).
|
interface |
RpcModule<S extends RpcRequest,T extends RpcResponse>
Provides the ability to execute the RPCs and defines how the requests/responses will
be marshaled/unmarshaled over the wire.
|
Modifier and Type | Method and Description |
---|---|
<R extends RpcRequest,S extends RpcResponse> |
RpcClientFactory.getClient(RpcModule<R,S> module) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.builder.RouteBuilder |
AmazonSQSServerRouteManager.getRouteBuilder(org.apache.camel.CamelContext context,
MinionIdentity identity,
RpcModule<RpcRequest,RpcResponse> module) |
Constructor and Description |
---|
AmazonSQSServerProcessor(RpcModule<RpcRequest,RpcResponse> module,
TracerRegistry tracerRegistry) |
Modifier and Type | Class and Description |
---|---|
class |
CamelRpcRequest<S extends RpcRequest,T extends RpcResponse>
Used to group the
RpcRequest and associated RpcModule . |
Modifier and Type | Method and Description |
---|---|
<S extends RpcRequest,T extends RpcResponse> |
CamelRpcClientFactory.getClient(RpcModule<S,T> module) |
Modifier and Type | Method and Description |
---|---|
abstract org.apache.camel.builder.RouteBuilder |
CamelRpcServerRouteManager.getRouteBuilder(org.apache.camel.CamelContext context,
MinionIdentity identity,
RpcModule<RpcRequest,RpcResponse> module) |
Constructor and Description |
---|
CamelRpcServerProcessor(RpcModule<RpcRequest,RpcResponse> module,
TracerRegistry tracerRegistry) |
Modifier and Type | Class and Description |
---|---|
class |
EchoResponse |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.builder.RouteBuilder |
JmsRpcServerRouteManager.getRouteBuilder(org.apache.camel.CamelContext context,
MinionIdentity identity,
RpcModule<RpcRequest,RpcResponse> module) |
Modifier and Type | Method and Description |
---|---|
<R extends RpcRequest,S extends RpcResponse> |
MockRpcClientFactory.getClient(RpcModule<R,S> module) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractXmlRpcModule<S extends RpcRequest,T extends RpcResponse>
RpcModule that uses JaxbUtils for marshaling and unmarshaling requests. |
Modifier and Type | Class and Description |
---|---|
class |
CollectorResponseDTO |
Modifier and Type | Class and Description |
---|---|
class |
PingResponseDTO |
class |
PingSweepResponseDTO |
Modifier and Type | Class and Description |
---|---|
class |
PollerResponseDTO |
Modifier and Type | Class and Description |
---|---|
class |
DetectorResponseDTO |
Modifier and Type | Class and Description |
---|---|
class |
DnsLookupResponseDTO |
Modifier and Type | Class and Description |
---|---|
class |
RequisitionResponseDTO |
Modifier and Type | Class and Description |
---|---|
class |
SnmpMultiResponseDTO |
Copyright © 2020. All rights reserved.