123.3. 生产端点

生产者端点可以接受并交付给 PubSub 个人并分组的交换。分组的交换设置有 Exchange.GROUPED_EXCHANGE 属性。

Google PubSub 要求有效负载可以是 byte[] 数组,Producer 端点将发送:

  • String body as byte[] encoded as UTF-8
  • byte[] body as is
  • 所有其他内容都被序列化为 byte[] 数组

a Map 设置为消息标题 GooglePubsubConstants.ATTRIBUTES 将以 PubSub 属性的形式发送。旦交换给 PubSub,PubSub Message ID 将分配给标头 GooglePubsubConstants.MESSAGE_ID