public class AckReplyConsumerWithResponseImpl implements AckReplyConsumerWithResponse
Implements
AckReplyConsumerWithResponseConstructors
AckReplyConsumerWithResponseImpl(SettableApiFuture<MessageDispatcher.AckReply> ackReplySettableApiFuture, SettableApiFuture<AckResponse> messageFuture)
public AckReplyConsumerWithResponseImpl(SettableApiFuture<MessageDispatcher.AckReply> ackReplySettableApiFuture, SettableApiFuture<AckResponse> messageFuture)
Parameters | |
---|---|
Name | Description |
ackReplySettableApiFuture |
SettableApiFuture<com.google.cloud.pubsub.v1.MessageDispatcher.AckReply> |
messageFuture |
SettableApiFuture<AckResponse> |
Methods
ack()
public ApiFuture<AckResponse> ack()
Acknowledges that the message has been successfully processed. The service will not send the message again.
A future representing the server response is returned
Returns | |
---|---|
Type | Description |
ApiFuture<AckResponse> |
nack()
public ApiFuture<AckResponse> nack()
Signals that the message has not been successfully processed. The service should resend the message.
A future representing the server response is returned
Returns | |
---|---|
Type | Description |
ApiFuture<AckResponse> |