public class SavepointDisposalHandlers.SavepointDisposalTriggerHandler extends AbstractAsynchronousOperationHandlers.TriggerHandler<RestfulGateway,SavepointDisposalRequest,EmptyMessageParameters>
TriggerHandler
implementation for the savepoint disposal operation.log, MAPPER
leaderRetriever, logger, responseHeaders, timeout
Constructor and Description |
---|
SavepointDisposalTriggerHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders) |
Modifier and Type | Method and Description |
---|---|
protected OperationKey |
createOperationKey(HandlerRequest<SavepointDisposalRequest> request)
Create the operation key under which the result future of the asynchronous operation will
be stored.
|
protected CompletableFuture<Acknowledge> |
triggerOperation(HandlerRequest<SavepointDisposalRequest> request,
RestfulGateway gateway)
Trigger the asynchronous operation and return its future result.
|
handleRequest
getMessageHeaders, respondToRequest
closeAsync, closeHandlerAsync, 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 SavepointDisposalTriggerHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders)
protected CompletableFuture<Acknowledge> triggerOperation(HandlerRequest<SavepointDisposalRequest> request, RestfulGateway gateway) throws RestHandlerException
AbstractAsynchronousOperationHandlers.TriggerHandler
triggerOperation
in class AbstractAsynchronousOperationHandlers.TriggerHandler<RestfulGateway,SavepointDisposalRequest,EmptyMessageParameters>
request
- with which the trigger handler has been calledgateway
- to the leaderRestHandlerException
- if something went wrongprotected OperationKey createOperationKey(HandlerRequest<SavepointDisposalRequest> request)
AbstractAsynchronousOperationHandlers.TriggerHandler
createOperationKey
in class AbstractAsynchronousOperationHandlers.TriggerHandler<RestfulGateway,SavepointDisposalRequest,EmptyMessageParameters>
request
- with which the trigger handler has been called.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.