Package | Description |
---|---|
com.google.cloud.pubsub.v1 |
A client to Cloud Pub/Sub API
|
Modifier and Type | Method and Description |
---|---|
static AckResponse |
AckResponse.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static AckResponse[] |
AckResponse.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
com.google.api.core.ApiFuture<AckResponse> |
AckReplyConsumerWithResponse.ack()
Acknowledges that the message has been successfully processed.
|
com.google.api.core.ApiFuture<AckResponse> |
AckReplyConsumerWithResponseImpl.ack() |
com.google.api.core.SettableApiFuture<AckResponse> |
AckRequestData.getMessageFutureIfExists() |
com.google.api.core.ApiFuture<AckResponse> |
AckReplyConsumerWithResponse.nack()
Signals that the message has not been successfully processed.
|
com.google.api.core.ApiFuture<AckResponse> |
AckReplyConsumerWithResponseImpl.nack() |
Modifier and Type | Method and Description |
---|---|
AckRequestData |
AckRequestData.setResponse(AckResponse ackResponse,
boolean setResponseOnSuccess) |
Modifier and Type | Method and Description |
---|---|
AckRequestData.Builder |
AckRequestData.Builder.setMessageFuture(com.google.api.core.SettableApiFuture<AckResponse> messageFuture) |
Constructor and Description |
---|
AckReplyConsumerWithResponseImpl(com.google.api.core.SettableApiFuture<MessageDispatcher.AckReply> ackReplySettableApiFuture,
com.google.api.core.SettableApiFuture<AckResponse> messageFuture) |
Copyright © 2023 Google LLC. All rights reserved.