public class SavepointHandlers.SavepointStatusHandler extends AbstractAsynchronousOperationHandlers.StatusHandler<RestfulGateway,SavepointInfo,SavepointStatusMessageParameters>
log, MAPPER
leaderRetriever, localAddressFuture, logger, responseHeaders, timeout
Constructor and Description |
---|
SavepointStatusHandler(CompletableFuture<String> localRestAddress,
GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders) |
Modifier and Type | Method and Description |
---|---|
protected SavepointInfo |
exceptionalOperationResultResponse(Throwable throwable)
Create an exceptional operation result from the given
Throwable . |
protected AsynchronousJobOperationKey |
getOperationKey(HandlerRequest<EmptyRequestBody,SavepointStatusMessageParameters> request)
Extract the operation key under which the operation result future is stored.
|
protected SavepointInfo |
operationResultResponse(String operationResult)
Create the operation result from the given value.
|
closeHandlerAsync, handleRequest
getMessageHeaders, respondToRequest
closeAsync, respondAsLeader
channelRead0
acceptInboundMessage, channelRead
channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered
handlerAdded, handlerRemoved, isSharable
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close
public SavepointStatusHandler(CompletableFuture<String> localRestAddress, GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders)
protected AsynchronousJobOperationKey getOperationKey(HandlerRequest<EmptyRequestBody,SavepointStatusMessageParameters> request)
AbstractAsynchronousOperationHandlers.StatusHandler
getOperationKey
in class AbstractAsynchronousOperationHandlers.StatusHandler<RestfulGateway,SavepointInfo,SavepointStatusMessageParameters>
request
- with which the status handler has been calledprotected SavepointInfo exceptionalOperationResultResponse(Throwable throwable)
AbstractAsynchronousOperationHandlers.StatusHandler
Throwable
. This
method is called if the asynchronous operation failed.exceptionalOperationResultResponse
in class AbstractAsynchronousOperationHandlers.StatusHandler<RestfulGateway,SavepointInfo,SavepointStatusMessageParameters>
throwable
- failure of the asynchronous operationprotected SavepointInfo operationResultResponse(String operationResult)
AbstractAsynchronousOperationHandlers.StatusHandler
operationResultResponse
in class AbstractAsynchronousOperationHandlers.StatusHandler<RestfulGateway,SavepointInfo,SavepointStatusMessageParameters>
operationResult
- of the asynchronous operationCopyright © 2014–2019 The Apache Software Foundation. All rights reserved.