io.micronaut.http.server

Class RouteExecutor

java.lang.Object

io.micronaut.http.server.RouteExecutor

@Singleton
public final class RouteExecutor
extends Object

A class responsible for executing routes.

Since:

3.0.0

Author:

James Kleeh

Constructor Summary

Constructors

Constructor and Description
RouteExecutor(Router router, BeanContext beanContext, RequestArgumentSatisfier requestArgumentSatisfier, HttpServerConfiguration serverConfiguration, ErrorResponseProcessor<?> errorResponseProcessor, ExecutorSelector executorSelector) Default constructor.

Method Summary

Modifier and Type	Method and Description
MutableHttpResponse<?>	createDefaultErrorResponse(HttpRequest<?> httpRequest, Throwable cause) Creates a default error response.
reactor.core.publisher.Flux<MutableHttpResponse<?>>	executeRoute(HttpRequest<?> request, boolean executeFilters, reactor.core.publisher.Flux<RouteMatch<?>> routePublisher) Executes a route.
Publisher<MutableHttpResponse<?>>	filterPublisher(AtomicReference<HttpRequest<?>> requestReference, Publisher<MutableHttpResponse<?>> upstreamResponsePublisher) Applies server filters to a request/response.
Optional<CoroutineHelper>	getCoroutineHelper()
ErrorResponseProcessor<?>	getErrorResponseProcessor()
ExecutorSelector	getExecutorSelector()
RequestArgumentSatisfier	getRequestArgumentSatisfier()
Router	getRouter()
reactor.core.publisher.Flux<MutableHttpResponse<?>>	onError(Throwable t, HttpRequest<?> httpRequest) Creates a response publisher to represent the response after being handled by any available error route or exception handler.
MediaType	resolveDefaultResponseContentType(HttpRequest<?> request, RouteInfo<?> finalRoute)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RouteExecutor

public RouteExecutor(Router router,
                     BeanContext beanContext,
                     RequestArgumentSatisfier requestArgumentSatisfier,
                     HttpServerConfiguration serverConfiguration,
                     ErrorResponseProcessor<?> errorResponseProcessor,
                     ExecutorSelector executorSelector)

Default constructor.

Parameters:

router - The router

beanContext - The bean context

requestArgumentSatisfier - The request argument satisfier

serverConfiguration - The server configuration

errorResponseProcessor - The error response processor

executorSelector - The executor selector

Method Detail

getRouter

@NonNull
public Router getRouter()

Returns:

The router

getRequestArgumentSatisfier

@Internal
 @NonNull
public RequestArgumentSatisfier getRequestArgumentSatisfier()

Returns:

The request argument satisfier

getErrorResponseProcessor

@NonNull
public ErrorResponseProcessor<?> getErrorResponseProcessor()

Returns:

The error response processor

getExecutorSelector

@NonNull
public ExecutorSelector getExecutorSelector()

Returns:

The executor selector

getCoroutineHelper

public Optional<CoroutineHelper> getCoroutineHelper()

Returns:

The kotlin coroutine helper

onError

public reactor.core.publisher.Flux<MutableHttpResponse<?>> onError(Throwable t,
                                                                   HttpRequest<?> httpRequest)

Creates a response publisher to represent the response after being handled by any available error route or exception handler.

Parameters:

t - The exception that occurred

httpRequest - The request that caused the exception

Returns:

A response publisher

createDefaultErrorResponse

public MutableHttpResponse<?> createDefaultErrorResponse(HttpRequest<?> httpRequest,
                                                         Throwable cause)

Creates a default error response. Should be used when a response could not be retrieved from any other method.

Parameters:

httpRequest - The request that case the exception

cause - The exception that occurred

Returns:

A response to represent the exception

resolveDefaultResponseContentType

public MediaType resolveDefaultResponseContentType(HttpRequest<?> request,
                                                   RouteInfo<?> finalRoute)

Parameters:

request - The request

finalRoute - The route

Returns:

The default content type declared on the route

executeRoute

public reactor.core.publisher.Flux<MutableHttpResponse<?>> executeRoute(HttpRequest<?> request,
                                                                        boolean executeFilters,
                                                                        reactor.core.publisher.Flux<RouteMatch<?>> routePublisher)

Executes a route.

Parameters:

request - The request that matched to the route

executeFilters - Whether or not to execute server filters

routePublisher - The route match publisher

Returns:

A response publisher

filterPublisher

public Publisher<MutableHttpResponse<?>> filterPublisher(AtomicReference<HttpRequest<?>> requestReference,
                                                         Publisher<MutableHttpResponse<?>> upstreamResponsePublisher)

Applies server filters to a request/response.

Parameters:

requestReference - The request reference

upstreamResponsePublisher - The original response publisher

Returns:

A new response publisher that executes server filters