Google PubSub getMessageID = null是否因为标记错误?

格雷马什

我很难从订户中的pubsub消息中获取消息ID。问题似乎是pubsub消息将ID存储在message_id字段中,但是getMessageId方法正在不存在的messageId字段中寻找消息ID。

我正在尝试从另一个应用程序发布的Pubsub消息中获取消息ID。JSON请求正文如下所示:

{
    "message": {
        "data": "SomeEncodedDate",
        "attributes": {
            "Published_Timestamp": "1438970954798"
        },
        "message_id": "1325068255839"
    },
    "subscription": "projects/MyProject/subscriptions/MySubscription"
}

我可以使用以下代码成功地重新创建消息:

JsonParser parser = JacksonFactory.getDefaultInstance().createJsonParser(jsonRequest);
parser.skipToKey("message");
PubsubMessage message = parser.parseAndClose(PubsubMessage.class);

如果我在调试器中查看消息,则它在message_id字段中具有有效的消息ID。但是,getMessageId()返回null。如果我使用setMessageId(“ SomeKey”)方法,则消息将包含一个带有新值的messageId新字段。现在,我的消息有两个ID字段,message_id和messageId。现在,调用getMessageId将返回messageId字段值,而不是pubsub消息中实际包含的message_id。

这是错误还是我做错了什么?

格雷马什

不幸的是,我还没有找到其他解决方案。我唯一能做的就是使用以下命令将应该是消息ID的内容复制到messageId字段中:message.setMessageId(message.get(“ message_id”)。toString()); 然后,我可以使用getMessageId方法。这只是一个错误。

本文收集自互联网,转载请注明来源。

如有侵权,请联系 [email protected] 删除。

编辑于
0

我来说两句

0 条评论
登录 后参与评论

相关文章

在/ protos中找不到Google pubsub错误google / pubsub / v1 / pubsub.proto

高效的Google PubSub发布

Google PubSub和GCM

App Engine的Google Cloud Pubsub身份验证错误

使Google Pubsub上的消息专用

Google Cloud Pubsub数据丢失

Google PubSub同时发布请求

如何修复 Google 地图中的重叠标记错误

将消息发布到 Google PubSub 时出现 StatusCode.PERMISSION_DENIED 错误

带有Google PubSub输入插件的Logstash“错误:证书验证失败”

遵循Google Cloud Scheduler / PubSub教程时出现“回调函数不是函数”错误

Google Cloud PubSub在异步请求中侦听消息时抛出504 Deadline Exceeded错误

Google PubSub:使用AppEngine推送端点进行订阅时出现SSL错误

Google云端引擎:用PubSub代替RabbitMQ

增加Google PubSub的截止期限超时

如何配置启用死信的 Google Pubsub 订阅?

Google Cloud Dataflow - 从 PubSub 到 Parquet

Google PubSub-按计划添加消息

Google PubSub-计算主题中的邮件

Google pubsub 88%的请求返回503

ACK消息在Google Pubsub上徘徊

Google Cloud PubSub 访问查询参数

基于属性或消息内容的Google Pubsub订阅

Google PubSub 可能存在编码问题

Google cloud SQL和Google pubsub一起出现问题:错误必须提供数据库名称

google.cloud.pubsub_v1和google.cloud.pubsub有什么区别?

Google PubSub / Gmail Webhook:发送电子邮件时始终从PubSub接收多个POST请求

尝试在 Google PubSub python 中创建主题订阅时出错

Apache Spark与Google PubSub的结构化流