io.smallrye.reactive.messaging.gcp.pubsub

Class PubSubMessage

java.lang.Object

io.smallrye.reactive.messaging.gcp.pubsub.PubSubMessage

All Implemented Interfaces:

Message<String>

public class PubSubMessage
extends Object
implements Message<String>

Field Summary

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

LOGGER

Constructor Summary

Constructors

Constructor and Description
PubSubMessage(com.google.pubsub.v1.PubsubMessage message)
PubSubMessage(com.google.pubsub.v1.PubsubMessage message, com.google.cloud.pubsub.v1.AckReplyConsumer ackReplyConsumer)

Method Summary

Modifier and Type	Method and Description
CompletionStage<Void>	ack() Acknowledge this message.
boolean	equals(Object o)
Supplier<CompletionStage<Void>>	getAck()
com.google.pubsub.v1.PubsubMessage	getMessage()
String	getPayload()
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, 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

PubSubMessage

public PubSubMessage(com.google.pubsub.v1.PubsubMessage message)

PubSubMessage

public PubSubMessage(com.google.pubsub.v1.PubsubMessage message,
                     com.google.cloud.pubsub.v1.AckReplyConsumer ackReplyConsumer)

Method Detail

getMessage

public com.google.pubsub.v1.PubsubMessage getMessage()

getPayload

public String getPayload()

Specified by:

getPayload in interface Message<String>

Returns:

The payload for this message.

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.

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object