@Component public class PingProxyRpcModule extends AbstractXmlRpcModule<PingRequestDTO,PingResponseDTO>
Modifier and Type | Field and Description |
---|---|
static String |
RPC_MODULE_ID |
MINION_HEADERS_MODULE
Constructor and Description |
---|
PingProxyRpcModule() |
Modifier and Type | Method and Description |
---|---|
PingResponseDTO |
createResponseWithException(Throwable ex)
Called when the
RpcModule throws an exception while executing a request. |
CompletableFuture<PingResponseDTO> |
execute(PingRequestDTO request) |
String |
getId()
Used to route the request/responses to the appropriate module.
|
void |
setPingerFactory(PingerFactory pingerFactory) |
marshalRequest, marshalResponse, unmarshalRequest, unmarshalResponse
public static final String RPC_MODULE_ID
public CompletableFuture<PingResponseDTO> execute(PingRequestDTO request)
public String getId()
RpcModule
public void setPingerFactory(PingerFactory pingerFactory)
public PingResponseDTO createResponseWithException(Throwable ex)
RpcModule
RpcModule
throws an exception while executing a request.
This function should return a new RpcResponse
that stores a string-based representation
of the exception that occurred and make this available via RpcResponse.getErrorMessage()
once un-marshaled.ex
- the exception that occurredRpcResponse
that stores the exceptionCopyright © 2021. All rights reserved.