来自Apache Camel路由的手动确认Google pubsub消息

import org.apache.camel.builder.RouteBuilder;
import com.google.cloud.pubsub.v1.AckReplyConsumer;
import com.google.cloud.pubsub.v1.MessageReceiver;
import com.google.cloud.pubsub.v1.Subscriber;
import com.google.pubsub.v1.PubsubMessage;
import com.google.pubsub.v1.SubscriptionName;

public class PubSubRoute extends RouteBuilder {
    @Override
    public void configure() throws Exception {
        // 设置Google Pub/Sub订阅名称
        String subscriptionName = "projects/{project}/subscriptions/{subscription}";

        // 创建Google Pub/Sub订阅者
        SubscriptionName subscription = SubscriptionName.parse(subscriptionName);
        MessageReceiver receiver = (message, consumer) -> {
            // 处理接收到的消息
            System.out.println("Received message: " + message.getData().toStringUtf8());

            // 手动确认消息
            consumer.ack();
        };
        Subscriber subscriber = Subscriber.newBuilder(subscription, receiver).build();

        // 启动订阅者
        subscriber.start();

        // 定义路由
        from("direct:pubsub")
            .to("google-pubsub:{{project-id}}:{{topic-id}}");

        // 关闭订阅者
        getContext().addShutdownHook(new Thread(() -> {
            subscriber.stopAsync().awaitTerminated();
        }));
    }
}

<dependencies>
    <dependency>
        <groupId>org.apache.camel</groupId>
        <artifactId>camel-google-pubsub</artifactId>
        <version>x.x.x</version>
    </dependency>
    <dependency>
        <groupId>com.google.cloud</groupId>
        <artifactId>google-cloud-pubsub</artifactId>
        <version>x.x.x</version>
    </dependency>
</dependencies>