使用 Spring Cloud Stream (StreamBridge) 包含自定义属性

Question

本文档介绍了如何将自定义属性包含到 PubSub 消息中。

https://cloud.google.com/pubsub/docs/samples/pubsub-publish-custom-attributes

使用较新的 Spring Cloud Stream 功能 API 是否可行？

streamBridge.send("myEvent-out-0", event)

我目前正在按照上述方式发布。第二个参数只是“对象”类型，因此无法区分自定义属性和常规属性。

谢谢

Answer 1

您可以发布 Spring Message 并将您的属性指定为 headers

streamBridge.send("myEvent-out-0", MessageBuilder
    .withPayload(event).setHeader("fooKey", "fooValue").setHeader("barKey", "barValue").build());