Class WebFluxNotificationMessageHandlerMethodArgumentResolver

java.lang.Object

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

io.awspring.cloud.sns.handlers.webflux.WebFluxNotificationMessageHandlerMethodArgumentResolver

All Implemented Interfaces:

HandlerMethodArgumentResolver

public class WebFluxNotificationMessageHandlerMethodArgumentResolver
extends WebFluxAbstractNotificationMessageHandlerMethodArgumentResolver

WebFlux argument resolver that handles conversion of SNS notification message payload to a method parameter annotated with NotificationMessage. Uses reactive Decoder instances instead of HttpMessageConverter.

This is the reactive counterpart of NotificationMessageHandlerMethodArgumentResolver.

Since:

4.1.0

Author:

Matej Nedic

Field Summary

Fields

Modifier and Type	Field	Description
static final List<Decoder<?>>	defaultDecoders

Constructor Summary

Constructors

Constructor	Description
WebFluxNotificationMessageHandlerMethodArgumentResolver()
WebFluxNotificationMessageHandlerMethodArgumentResolver(List<Decoder<?>> decoders)
WebFluxNotificationMessageHandlerMethodArgumentResolver(List<Decoder<?>> decoders, @Nullable software.amazon.awssdk.messagemanager.sns.SnsMessageManager snsMessageManager)

Method Summary

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

Methods inherited from class WebFluxAbstractNotificationMessageHandlerMethodArgumentResolver

resolveArgument

Methods inherited from class Object

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

Field Details

defaultDecoders

public static final List<Decoder<?>> defaultDecoders

Constructor Details

WebFluxNotificationMessageHandlerMethodArgumentResolver

public WebFluxNotificationMessageHandlerMethodArgumentResolver()

WebFluxNotificationMessageHandlerMethodArgumentResolver

public WebFluxNotificationMessageHandlerMethodArgumentResolver(List<Decoder<?>> decoders)

WebFluxNotificationMessageHandlerMethodArgumentResolver

public WebFluxNotificationMessageHandlerMethodArgumentResolver(List<Decoder<?>> decoders,
 @Nullable software.amazon.awssdk.messagemanager.sns.SnsMessageManager snsMessageManager)

Method Details

supportsParameter

public boolean supportsParameter(MethodParameter parameter)

doResolveArgumentFromNotificationMessage

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

Specified by:

doResolveArgumentFromNotificationMessage in class WebFluxAbstractNotificationMessageHandlerMethodArgumentResolver