概述
使用消息队列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版