在java中重试来自GCP pub/sub的消息需要哪些设置

Message message = Message.newBuilder()
    .setData(ByteString.copyFromUtf8("Hello, Pub/Sub!"))
    .putAttributes("key", "value")
    .setRetryPolicy(RetryPolicy.newBuilder().setMaximumAttempts(3).build())
    .build();

Message message = Message.newBuilder()
    .setData(ByteString.copyFromUtf8("Hello, Pub/Sub!"))
    .putAttributes("key", "value")
    .setRetryPolicy(RetryPolicy.newBuilder()
        .setMinimumBackoff(Duration.ofSeconds(1))
        .setMaximumBackoff(Duration.ofMinutes(1))
        .build())
    .build();

Subscriber subscriber = Subscriber.newBuilder(subscription, messageReceiver).build();
subscriber.startAsync().awaitRunning();

// MessageReceiver implementation
public class MyMessageReceiver implements MessageReceiver {
    @Override
    public void receiveMessage(PubsubMessage message, AckReplyConsumer consumer) {
        int retryCount = Integer.parseInt(message.getAttributesOrDefault("googclient_retryCount", "0"));
        if (retryCount > 0) {
            // 处理重试逻辑
        } else {
            // 处理正常消息逻辑
        }
        consumer.ack();
    }
}