Class WebFluxAbstractNotificationMessageHandlerMethodArgumentResolver

java.lang.Object

io.awspring.cloud.sns.handlers.webflux.WebFluxAbstractNotificationMessageHandlerMethodArgumentResolver

All Implemented Interfaces:

HandlerMethodArgumentResolver

Direct Known Subclasses:

WebFluxNotificationMessageHandlerMethodArgumentResolver, WebFluxNotificationStatusHandlerMethodArgumentResolver, WebFluxNotificationSubjectHandlerMethodArgumentResolver

public abstract class WebFluxAbstractNotificationMessageHandlerMethodArgumentResolver
extends Object
implements HandlerMethodArgumentResolver

Base class for WebFlux argument resolvers that handle SNS HTTP notification messages. Reads and caches the request body as a JsonNode in the ServerWebExchange attributes so that multiple resolvers can access the same parsed notification without re-reading the body.

This is the reactive counterpart of AbstractNotificationMessageHandlerMethodArgumentResolver.

Since:

4.1.0

Author:

Matej Nedic

Constructor Summary

Constructors

Constructor	Description
WebFluxAbstractNotificationMessageHandlerMethodArgumentResolver()

Method Summary

Modifier and Type	Method	Description
protected abstract reactor.core.publisher.Mono<Object>	doResolveArgumentFromNotificationMessage(tools.jackson.databind.JsonNode content, ServerWebExchange exchange, Class<?> parameterType)
reactor.core.publisher.Mono<Object>	resolveArgument(MethodParameter parameter, BindingContext bindingContext, ServerWebExchange exchange)

Methods inherited from class Object

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

Methods inherited from interface HandlerMethodArgumentResolver

supportsParameter

Constructor Details

WebFluxAbstractNotificationMessageHandlerMethodArgumentResolver

public WebFluxAbstractNotificationMessageHandlerMethodArgumentResolver()

Method Details

resolveArgument

public reactor.core.publisher.Mono<Object> resolveArgument(MethodParameter parameter,
 BindingContext bindingContext,
 ServerWebExchange exchange)

Specified by:

resolveArgument in interface HandlerMethodArgumentResolver

doResolveArgumentFromNotificationMessage

protected abstract reactor.core.publisher.Mono<Object> doResolveArgumentFromNotificationMessage(tools.jackson.databind.JsonNode content,
 ServerWebExchange exchange,
 Class<?> parameterType)