使用消息队列RocketMQ版时message类的userproperties属性如何自定义

使用消息队列RocketMQ版时message类的userproperties属性如何自定义

更新时间:2020-06-19 17:50:02

概述

使用消息队列RocketMQ版时,message类的userproperties属性如何自定义。

详细信息

userproperties属性是Properties类型,您可以根据自己的需求添加Key-Value类型的属性到message中,示例如下:

Message message = new Message(MqConfig.TOPIC, MqConfig.TAG, "mq send message test".getBytes());
Properties properties = new Properties();
properties.setProperty("key1","value1");
message.setUserProperties(properties);

适用于

  • 消息队列RocketMQ版