T
- type of the gatewayR
- type of the REST responseM
- type of the MessageParameterspublic class LegacyRestHandlerAdapter<T extends RestfulGateway,R extends ResponseBody,M extends MessageParameters> extends AbstractRestHandler<T,EmptyRequestBody,R,M>
log
leaderRetriever, localAddressFuture, logger, timeout
Constructor and Description |
---|
LegacyRestHandlerAdapter(CompletableFuture<String> localRestAddress,
GatewayRetriever<T> leaderRetriever,
Time timeout,
MessageHeaders<EmptyRequestBody,R,M> messageHeaders,
LegacyRestHandler<T,R,M> legacyRestHandler) |
Modifier and Type | Method and Description |
---|---|
protected CompletableFuture<R> |
handleRequest(HandlerRequest<EmptyRequestBody,M> request,
T gateway)
This method is called for every incoming request and returns a
CompletableFuture containing a the response. |
getMessageHeaders, respondAsLeader
channelRead0
acceptInboundMessage, channelRead
channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered
handlerAdded, handlerRemoved, isSharable
public LegacyRestHandlerAdapter(CompletableFuture<String> localRestAddress, GatewayRetriever<T> leaderRetriever, Time timeout, MessageHeaders<EmptyRequestBody,R,M> messageHeaders, LegacyRestHandler<T,R,M> legacyRestHandler)
protected CompletableFuture<R> handleRequest(@Nonnull HandlerRequest<EmptyRequestBody,M> request, @Nonnull T gateway) throws RestHandlerException
AbstractRestHandler
CompletableFuture
containing a the response.
Implementations may decide whether to throw RestHandlerException
s or fail the returned
CompletableFuture
with a RestHandlerException
.
Failing the future with another exception type or throwing unchecked exceptions is regarded as an
implementation error as it does not allow us to provide a meaningful HTTP status code. In this case a
HttpResponseStatus.INTERNAL_SERVER_ERROR
will be returned.
handleRequest
in class AbstractRestHandler<T extends RestfulGateway,EmptyRequestBody,R extends ResponseBody,M extends MessageParameters>
request
- request that should be handledgateway
- leader gatewayRestHandlerException
- if the handling failedCopyright © 2014–2018 The Apache Software Foundation. All rights reserved.