io.smallrye.reactive.messaging.aws.sns

Class SnsMessage

java.lang.Object

io.smallrye.reactive.messaging.aws.sns.SnsMessage

All Implemented Interfaces:

Message<String>

public class SnsMessage
extends Object
implements Message<String>

Implementation of Message for SNS. Currently, it only support payload of type String.

Author:

iabughosh

Field Summary

Fields inherited from interface org.eclipse.microprofile.reactive.messaging.Message

LOGGER

Constructor Summary

Constructors

Constructor and Description
SnsMessage(com.amazonaws.services.sns.message.SnsNotification snsNotification) Constructor for AWS SNS.
SnsMessage(String payload) Constructor for fake SNS.

Method Summary

Modifier and Type	Method and Description
CompletionStage<Void>	ack() Acknowledge this message.
Supplier<CompletionStage<Void>>	getAck()
String	getPayload()
String	getSubject() Get message subject of SNS notification.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.eclipse.microprofile.reactive.messaging.Message

addMetadata, getMetadata, getMetadata, getNack, nack, of, of, of, of, of, of, of, of, of, unwrap, withAck, withMetadata, withMetadata, withNack, withPayload

Constructor Detail

SnsMessage

public SnsMessage(com.amazonaws.services.sns.message.SnsNotification snsNotification)

Constructor for AWS SNS.

Parameters:

snsNotification - the notification, must not be null

SnsMessage

public SnsMessage(String payload)

Constructor for fake SNS.

Parameters:

payload - the payload.

Method Detail

ack

public CompletionStage<Void> ack()

Description copied from interface: Message

Acknowledge this message.

Specified by:

ack in interface Message<String>

Returns:

a completion stage completed when the message is acknowledged. If the acknowledgement fails, the completion stage propagates the failure.

getAck

public Supplier<CompletionStage<Void>> getAck()

Specified by:

getAck in interface Message<String>

Returns:

the supplier used to retrieve the acknowledgement CompletionStage.

getPayload

public String getPayload()

Specified by:

getPayload in interface Message<String>

Returns:

The payload for this message.

getSubject

public String getSubject()

Get message subject of SNS notification.

Returns:

message subject.