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

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.
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, getAck, getMetadata, getMetadata, of, of, of, of, of, of, unwrap, withAck, withMetadata, withMetadata, 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.

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.