修改异步订阅服务器中的ack截止日期

Question

我目前切换到google-cloud-pubsub库的0.24.0-beta版本，无法找到修改消息确认截止日期的方法。在以前的版本中，有一个modifyAckDeadline()，它允许我这样做。在新版本中可能吗？

为了了解我为什么要尝试它:我想实现的是一种重试机制，在这种机制中，无法处理的消息会在10分钟内重新传递，并且只有在X次不成功的重试之后才会被确认。

Answer 1

为了保留消息的租约，因为它需要更长的处理时间，新版本的订阅者库在后台为您调用modifyAckDeadline。只要消息是未完成的，也就是说，您还没有对MessageReceiver通过消息接收到的AckReplyConsumer调用ack()或nack()，库本身就会对消息调用modifyAckDeadline。

您的目标略有不同:您希望使用modifyAckDeadline在一段时间内尽最大努力防止消息重新传递。然后，当你不能处理一条消息时，不要对消息进行ack或nack。客户端库将继续modifyAckDeadline 10分钟，之后可以重新传递消息。