@Component public class PingSweepRpcModule extends AbstractXmlRpcModule<PingSweepRequestDTO,PingSweepResponseDTO>
Modifier and Type | Field and Description |
---|---|
static String |
RPC_MODULE_ID |
MINION_HEADERS_MODULE
Constructor and Description |
---|
PingSweepRpcModule() |
Modifier and Type | Method and Description |
---|---|
PingSweepResponseDTO |
createResponseWithException(Throwable ex)
Called when the
RpcModule throws an exception while executing a request. |
CompletableFuture<PingSweepResponseDTO> |
execute(PingSweepRequestDTO request) |
Iterable<IPPollAddress> |
getAddresses(List<IPPollRange> ranges) |
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<PingSweepResponseDTO> execute(PingSweepRequestDTO request)
public PingSweepResponseDTO 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 exceptionpublic String getId()
RpcModule
public void setPingerFactory(PingerFactory pingerFactory)
public Iterable<IPPollAddress> getAddresses(List<IPPollRange> ranges)
Copyright © 2021. All rights reserved.