使用 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)

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

谢谢

Answer 1

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

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