Class WebFluxNotificationStatusHandlerMethodArgumentResolver

java.lang.Object

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

io.awspring.cloud.sns.handlers.webflux.WebFluxNotificationStatusHandlerMethodArgumentResolver

All Implemented Interfaces:

HandlerMethodArgumentResolver

public class WebFluxNotificationStatusHandlerMethodArgumentResolver
extends WebFluxAbstractNotificationMessageHandlerMethodArgumentResolver

WebFlux argument resolver that handles SNS subscription and unsubscription confirmation events by resolving them to a NotificationStatus instance, which can be used to confirm or re-confirm subscriptions.

This is the reactive counterpart of NotificationStatusHandlerMethodArgumentResolver.

Since:

4.1.0

Author:

Matej Nedic

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	WebFluxNotificationStatusHandlerMethodArgumentResolver.AmazonSnsNotificationStatus

Constructor Summary

Constructors

Constructor	Description
WebFluxNotificationStatusHandlerMethodArgumentResolver(software.amazon.awssdk.services.sns.SnsClient snsClient)
WebFluxNotificationStatusHandlerMethodArgumentResolver(software.amazon.awssdk.services.sns.SnsClient snsClient, @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

Constructor Details

WebFluxNotificationStatusHandlerMethodArgumentResolver

public WebFluxNotificationStatusHandlerMethodArgumentResolver(software.amazon.awssdk.services.sns.SnsClient snsClient)

WebFluxNotificationStatusHandlerMethodArgumentResolver

public WebFluxNotificationStatusHandlerMethodArgumentResolver(software.amazon.awssdk.services.sns.SnsClient snsClient,
 @Nullable software.amazon.awssdk.messagemanager.sns.SnsMessageManager snsMessageManager)

Method Details

doResolveArgumentFromNotificationMessage

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

Specified by:

doResolveArgumentFromNotificationMessage in class WebFluxAbstractNotificationMessageHandlerMethodArgumentResolver

supportsParameter

public boolean supportsParameter(MethodParameter parameter)