Constructor and Description |
---|
PubSubMessage(com.google.pubsub.v1.PubsubMessage message) |
PubSubMessage(com.google.pubsub.v1.PubsubMessage message,
com.google.cloud.pubsub.v1.AckReplyConsumer ackReplyConsumer) |
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() |
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
addMetadata, getMetadata, getMetadata, getNack, nack, of, of, of, of, of, of, of, of, of, unwrap, withAck, withMetadata, withMetadata, withNack, withPayload
public PubSubMessage(com.google.pubsub.v1.PubsubMessage message)
public PubSubMessage(com.google.pubsub.v1.PubsubMessage message, com.google.cloud.pubsub.v1.AckReplyConsumer ackReplyConsumer)
public com.google.pubsub.v1.PubsubMessage getMessage()
public String getPayload()
getPayload
in interface Message<String>
public CompletionStage<Void> ack()
Message
public Supplier<CompletionStage<Void>> getAck()
getAck
in interface Message<String>
CompletionStage
.Copyright © 2018–2021 SmallRye. All rights reserved.