Class PollerClientRpcModule
- java.lang.Object
-
- org.opennms.core.rpc.xml.AbstractXmlRpcModule<PollerRequestDTO,PollerResponseDTO>
-
- org.opennms.netmgt.poller.client.rpc.PollerClientRpcModule
-
- All Implemented Interfaces:
RpcClient<PollerRequestDTO,PollerResponseDTO>
,RpcModule<PollerRequestDTO,PollerResponseDTO>
public class PollerClientRpcModule extends AbstractXmlRpcModule<PollerRequestDTO,PollerResponseDTO>
-
-
Field Summary
Fields Modifier and Type Field Description static String
RPC_MODULE_ID
-
Fields inherited from interface org.opennms.core.rpc.api.RpcModule
MINION_HEADERS_MODULE
-
-
Constructor Summary
Constructors Constructor Description PollerClientRpcModule()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description PollerResponseDTO
createResponseWithException(Throwable ex)
Called when theRpcModule
throws an exception while executing a request.CompletableFuture<PollerResponseDTO>
execute(PollerRequestDTO request)
String
getId()
Used to route the request/responses to the appropriate module.void
setExecutor(Executor executor)
void
setServiceMonitorRegistry(ServiceMonitorRegistry serviceMonitorRegistry)
-
Methods inherited from class org.opennms.core.rpc.xml.AbstractXmlRpcModule
marshalRequest, marshalResponse, unmarshalRequest, unmarshalResponse
-
-
-
-
Field Detail
-
RPC_MODULE_ID
public static final String RPC_MODULE_ID
- See Also:
- Constant Field Values
-
-
Method Detail
-
getId
public String getId()
Description copied from interface:RpcModule
Used to route the request/responses to the appropriate module. This ID should be unique for every RpcModule implementation.
-
execute
public CompletableFuture<PollerResponseDTO> execute(PollerRequestDTO request)
-
setServiceMonitorRegistry
public void setServiceMonitorRegistry(ServiceMonitorRegistry serviceMonitorRegistry)
-
setExecutor
public void setExecutor(Executor executor)
-
createResponseWithException
public PollerResponseDTO createResponseWithException(Throwable ex)
Description copied from interface:RpcModule
Called when theRpcModule
throws an exception while executing a request. This function should return a newRpcResponse
that stores a string-based representation of the exception that occurred and make this available viaRpcResponse.getErrorMessage()
once un-marshaled.- Parameters:
ex
- the exception that occurred- Returns:
- a
RpcResponse
that stores the exception
-
-