当前位置: 首页 > 知识库问答 >
问题:

来自Apache Camel route的手动ack谷歌pubsub消息

贾飞章
2023-03-14

任何关于我如何做到这一点的想法或任何可以帮助我的例子。谢谢你。

共有1个答案

陆正德
2023-03-14

据说这应该有效:

在您的骆驼路由中添加一个处理器,它执行以下操作:

exchange.getUnitOfWork().done(exchange);

不管消息的来源是什么,它都应该访问消息(在这种情况下是google pubsub)...

 类似资料:
  • null null 谢谢!!!

  • 我正在尝试使用Google Cloud Dataflow(Python SDK)将Google PubSub消息写入Google Cloud Storage。这些消息以json格式进入PubSub,我必须定义一个模式才能将它们写入Google Cloud Storage中的拼花格式。 根据其他用户的建议,我开始着手这项任务,特别是查看这个和这个来源。< br >第一个不是我想要做的,因为它将更改应

  • 我看到的问题是,当我向另一个用户发送消息时,PubSub似乎在一秒钟内两次使用略有不同的history_id和message_id,但订阅名称和用户电子邮件都是相同的。 我知道PubSub保证至少一次交付,所以接收重复的消息并不是不合理的,但因为它一直在发生,而且message_id不同,我认为根据下面的PubSub文档,可能会有多个推送请求: Cloud pub/sub为每个消息分配唯一的,该消

  • 如何防止重复味精在谷歌云PubSub中发生?

  • 上面写着“Google Cloud Messaging(GCM)是一个免费服务”,但是为了使它能够运行,我需要在Google Cloud平台中创建一个项目,这需要花钱…那怎么免费呢?还是我错过了什么?

  • 我正在尝试使用谷歌云数据流将谷歌PubSub消息写入谷歌云存储。PubSub消息采用json格式,我要执行的唯一操作是从json到parquet文件的转换。