public class SavepointDisposalHandlers.SavepointDisposalStatusHandler extends AbstractAsynchronousOperationHandlers.StatusHandler<RestfulGateway,AsynchronousOperationInfo,SavepointDisposalStatusMessageParameters>
StatusHandler
implementation for the savepoint disposal operation.log, MAPPER
leaderRetriever, logger, responseHeaders, timeout
Constructor and Description |
---|
SavepointDisposalStatusHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders) |
Modifier and Type | Method and Description |
---|---|
protected AsynchronousOperationInfo |
exceptionalOperationResultResponse(Throwable throwable)
Create an exceptional operation result from the given
Throwable . |
protected OperationKey |
getOperationKey(HandlerRequest<EmptyRequestBody,SavepointDisposalStatusMessageParameters> request)
Extract the operation key under which the operation result future is stored.
|
protected AsynchronousOperationInfo |
operationResultResponse(Acknowledge 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
ensureNotSharable, handlerAdded, handlerRemoved, isSharable
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close
public SavepointDisposalStatusHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders)
protected OperationKey getOperationKey(HandlerRequest<EmptyRequestBody,SavepointDisposalStatusMessageParameters> request)
AbstractAsynchronousOperationHandlers.StatusHandler
getOperationKey
in class AbstractAsynchronousOperationHandlers.StatusHandler<RestfulGateway,AsynchronousOperationInfo,SavepointDisposalStatusMessageParameters>
request
- with which the status handler has been calledprotected AsynchronousOperationInfo exceptionalOperationResultResponse(Throwable throwable)
AbstractAsynchronousOperationHandlers.StatusHandler
Throwable
. This method is
called if the asynchronous operation failed.exceptionalOperationResultResponse
in class AbstractAsynchronousOperationHandlers.StatusHandler<RestfulGateway,AsynchronousOperationInfo,SavepointDisposalStatusMessageParameters>
throwable
- failure of the asynchronous operationprotected AsynchronousOperationInfo operationResultResponse(Acknowledge operationResult)
AbstractAsynchronousOperationHandlers.StatusHandler
operationResultResponse
in class AbstractAsynchronousOperationHandlers.StatusHandler<RestfulGateway,AsynchronousOperationInfo,SavepointDisposalStatusMessageParameters>
operationResult
- of the asynchronous operationCopyright © 2014–2021 The Apache Software Foundation. All rights reserved.