org.apache.rocketmq.common.message.Message.putUserProperty()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(9.1k)|赞(0)|评价(0)|浏览(229)

本文整理了Java中org.apache.rocketmq.common.message.Message.putUserProperty()方法的一些代码示例，展示了Message.putUserProperty()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Message.putUserProperty()方法的具体详情如下：
包路径：org.apache.rocketmq.common.message.Message
类名称：Message
方法名：putUserProperty

Message.putUserProperty介绍

暂无

代码示例

代码示例来源：origin: apache/rocketmq

  1. String prop1 = "prop" + i, prop1V = "hello" + startValue;
  2. String prop2 = "prop" + (i + 1), prop2V = String.valueOf(startValue);
  3. msg.putUserProperty(prop1, prop1V);
  4. msg.putUserProperty(prop2, prop2V);
  5. size += prop1.length() + prop2.length() + prop1V.length() + prop2V.length();
  6. if (size > propertySize) {

代码示例来源：origin: apache/rocketmq-externals

  1. rocketmqMsg.setBuyerId(value);
  2. } else {
  3.   rocketmqMsg.putUserProperty(name, value);

代码示例来源：origin: spring-cloud-incubator/spring-cloud-alibaba

  1. for (Map.Entry<String, String> entry : headerAccessor.getUserProperties()
  2.     .entrySet()) {
  3.   toSend.putUserProperty(entry.getKey(), entry.getValue());

代码示例来源：origin: apache/rocketmq

  1. public static org.apache.rocketmq.common.message.Message msgConvert(BytesMessage omsMessage) {
  2.   org.apache.rocketmq.common.message.Message rmqMessage = new org.apache.rocketmq.common.message.Message();
  3.   rmqMessage.setBody(omsMessage.getBody(byte[].class));
  4.   KeyValue sysHeaders = omsMessage.sysHeaders();
  5.   KeyValue userHeaders = omsMessage.userHeaders();
  6.   //All destinations in RocketMQ use Topic
  7.   rmqMessage.setTopic(sysHeaders.getString(BuiltinKeys.DESTINATION));
  8.   if (sysHeaders.containsKey(BuiltinKeys.START_TIME)) {
  9.     long deliverTime = sysHeaders.getLong(BuiltinKeys.START_TIME, 0);
  10.     if (deliverTime > 0) {
  11.       rmqMessage.putUserProperty(RocketMQConstants.START_DELIVER_TIME, String.valueOf(deliverTime));
  12.     }
  13.   }
  14.   for (String key : userHeaders.keySet()) {
  15.     MessageAccessor.putProperty(rmqMessage, key, userHeaders.getString(key));
  16.   }
  17.   //System headers has a high priority
  18.   for (String key : sysHeaders.keySet()) {
  19.     MessageAccessor.putProperty(rmqMessage, key, sysHeaders.getString(key));
  20.   }
  21.   return rmqMessage;
  22. }

代码示例来源：origin: apache/rocketmq

  1. /**
  2.    * @since version3.4.6
  3.    */
  4.   @Test
  5.   public void testSendChinaUserProp() {
  6.     Message msg = MessageFactory.getRandomMessage(topic);
  7.     String msgKey = "jueyinKey";
  8.     String msgValue = "jueyinzhi";
  9.     msg.putUserProperty(msgKey, msgValue);
  11.     RMQNormalConsumer consumer = getConsumer(nsAddr, topic, "*", new RMQNormalListener());
  13.     producer.send(msg, null);
  14.     assertThat(producer.getAllMsgBody().size()).isEqualTo(1);
  16.     consumer.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime);
  18.     Message sendMsg = (Message) producer.getFirstMsg();
  19.     Message recvMsg = (Message) consumer.getListener().getFirstMsg();
  20.     assertThat(recvMsg.getUserProperty(msgKey)).isEqualTo(sendMsg.getUserProperty(msgKey));
  21.   }
  22. }

代码示例来源：origin: apache/rocketmq

  1. /**
  2.  * @since version3.4.6
  3.  */
  4. @Test
  5. public void testSendEnglishUserProp() {
  6.   Message msg = MessageFactory.getRandomMessage(topic);
  7.   String msgKey = "jueyinKey";
  8.   String msgValue = "jueyinValue";
  9.   msg.putUserProperty(msgKey, msgValue);
  10.   RMQNormalConsumer consumer = getConsumer(nsAddr, topic, "*", new RMQNormalListener());
  11.   producer.send(msg, null);
  12.   assertThat(producer.getAllMsgBody().size()).isEqualTo(1);
  13.   consumer.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime);
  14.   Message sendMsg = (Message) producer.getFirstMsg();
  15.   Message recvMsg = (Message) consumer.getListener().getFirstMsg();
  16.   assertThat(recvMsg.getUserProperty(msgKey)).isEqualTo(sendMsg.getUserProperty(msgKey));
  17. }

代码示例来源：origin: apache/rocketmq

  1. try {
  2.   if (sendResult.getTransactionId() != null) {
  3.     msg.putUserProperty("__transactionId__", sendResult.getTransactionId());

代码示例来源：origin: didi/DDMQ

  1. public static void main(String[] args) throws MQClientException, InterruptedException {
  2.     DefaultMQProducer producer = new DefaultMQProducer("ProducerGroupName");
  3.     producer.start();
  5.     try {
  6.       for (int i = 0; i < 6000000; i++) {
  7.         Message msg = new Message("TopicFilter7",
  8.           "TagA",
  9.           "OrderID001",
  10.           "Hello world".getBytes(RemotingHelper.DEFAULT_CHARSET));
  12.         msg.putUserProperty("SequenceId", String.valueOf(i));
  13.         SendResult sendResult = producer.send(msg);
  14.         System.out.printf("%s%n", sendResult);
  15.       }
  16.     } catch (Exception e) {
  17.       e.printStackTrace();
  18.     }
  19.     producer.shutdown();
  20.   }
  21. }

代码示例来源：origin: javahongxi/whatsmars

  1. && !Objects.equals(entry.getKey(), "WAIT_STORE_MSG_OK")) // exclude "KEYS", "FLAG", "WAIT_STORE_MSG_OK"
  2. .forEach(entry -> {
  3.   rocketMsg.putUserProperty("USERS_" + entry.getKey(), String.valueOf(entry.getValue())); // add other properties with prefix "USERS_"
  4. });

代码示例来源：origin: didi/DDMQ

  1. ("Hello RocketMQ " + i).getBytes(RemotingHelper.DEFAULT_CHARSET)
  2. );
  3. msg.putUserProperty("a", String.valueOf(i));

代码示例来源：origin: didi/DDMQ

  1. String prop1 = "prop" + i, prop1V = "hello" + startValue;
  2. String prop2 = "prop" + (i + 1), prop2V = String.valueOf(startValue);
  3. msg.putUserProperty(prop1, prop1V);
  4. msg.putUserProperty(prop2, prop2V);
  5. size += prop1.length() + prop2.length() + prop1V.length() + prop2V.length();
  6. if (size > propertySize) {

代码示例来源：origin: didi/DDMQ

  1. /**
  2.  * @since version3.4.6
  3.  */
  4. @Test(expected = org.apache.rocketmq.client.exception.MQBrokerException.class)
  5. public void testSend20kChinaPropMsg() throws Exception {
  6.   Message msg = MessageFactory.getRandomMessage(topic);
  7.   msg.putUserProperty("key", RandomUtils.getCheseWord(32 * 1024 + 1));
  8.   producer.send(msg);
  9. }

代码示例来源：origin: didi/DDMQ

  1. public static org.apache.rocketmq.common.message.Message msgConvert(BytesMessage omsMessage) {
  2.   org.apache.rocketmq.common.message.Message rmqMessage = new org.apache.rocketmq.common.message.Message();
  3.   rmqMessage.setBody(omsMessage.getBody());
  4.   KeyValue headers = omsMessage.headers();
  5.   KeyValue properties = omsMessage.properties();
  6.   //All destinations in RocketMQ use Topic
  7.   if (headers.containsKey(MessageHeader.TOPIC)) {
  8.     rmqMessage.setTopic(headers.getString(MessageHeader.TOPIC));
  9.     rmqMessage.putUserProperty(NonStandardKeys.MESSAGE_DESTINATION, "TOPIC");
  10.   } else {
  11.     rmqMessage.setTopic(headers.getString(MessageHeader.QUEUE));
  12.     rmqMessage.putUserProperty(NonStandardKeys.MESSAGE_DESTINATION, "QUEUE");
  13.   }
  14.   for (String key : properties.keySet()) {
  15.     MessageAccessor.putProperty(rmqMessage, key, properties.getString(key));
  16.   }
  17.   //Headers has a high priority
  18.   for (String key : headers.keySet()) {
  19.     MessageAccessor.putProperty(rmqMessage, key, headers.getString(key));
  20.   }
  21.   return rmqMessage;
  22. }

代码示例来源：origin: didi/DDMQ

  1. @Test
  2.   public void testSendMsgWithUserProperty() {
  3.     Message msg = MessageFactory.getRandomMessage(topic);
  4.     msg.putUserProperty("key", RandomUtils.getCheseWord(10 * 1024));
  5.     SendResult sendResult = null;
  6.     try {
  7.       sendResult = producer.send(msg);
  8.     } catch (Exception e) {
  9.     }
  10.     assertThat(sendResult.getSendStatus()).isEqualTo(SendStatus.SEND_OK);
  11.   }
  12. }

代码示例来源：origin: didi/DDMQ

  1. /**
  2.    * @since version3.4.6
  3.    */
  4.   @Test
  5.   public void testSend10kChinaPropMsg() {
  7.     Message msg = MessageFactory.getRandomMessage(topic);
  8.     msg.putUserProperty("key", RandomUtils.getCheseWord(10 * 1024));
  9.     SendResult sendResult = null;
  10.     try {
  11.       sendResult = producer.send(msg);
  12.     } catch (Exception e) {
  13.     }
  14.     assertThat(sendResult.getSendStatus()).isEqualTo(SendStatus.SEND_OK);
  15.   }
  16. }

代码示例来源：origin: didi/DDMQ

  1. try {
  2.   if (sendResult.getTransactionId() != null) {
  3.     msg.putUserProperty("__transactionId__", sendResult.getTransactionId());

代码示例来源：origin: didi/DDMQ

  1. /**
  2.  * @since version3.4.6
  3.  */
  4. @Test
  5. public void testSendEnglishUserProp() {
  6.   Message msg = MessageFactory.getRandomMessage(topic);
  7.   String msgKey = "jueyinKey";
  8.   String msgValue = "jueyinValue";
  9.   msg.putUserProperty(msgKey, msgValue);
  10.   RMQNormalConsumer consumer = getConsumer(nsAddr, topic, "*", new RMQNormalListener());
  11.   producer.send(msg, null);
  12.   assertThat(producer.getAllMsgBody().size()).isEqualTo(1);
  13.   consumer.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime);
  14.   Message sendMsg = (Message) producer.getFirstMsg();
  15.   Message recvMsg = (Message) consumer.getListener().getFirstMsg();
  16.   assertThat(recvMsg.getUserProperty(msgKey)).isEqualTo(sendMsg.getUserProperty(msgKey));
  17. }

代码示例来源：origin: didi/DDMQ

  1. /**
  2.    * @since version3.4.6
  3.    */
  4.   @Test
  5.   public void testSendChinaUserProp() {
  6.     Message msg = MessageFactory.getRandomMessage(topic);
  7.     String msgKey = "jueyinKey";
  8.     String msgValue = "jueyinzhi";
  9.     msg.putUserProperty(msgKey, msgValue);
  11.     RMQNormalConsumer consumer = getConsumer(nsAddr, topic, "*", new RMQNormalListener());
  13.     producer.send(msg, null);
  14.     assertThat(producer.getAllMsgBody().size()).isEqualTo(1);
  16.     consumer.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime);
  18.     Message sendMsg = (Message) producer.getFirstMsg();
  19.     Message recvMsg = (Message) consumer.getListener().getFirstMsg();
  20.     assertThat(recvMsg.getUserProperty(msgKey)).isEqualTo(sendMsg.getUserProperty(msgKey));
  21.   }
  22. }

代码示例来源：origin: jiangxinlingdu/rocketmq-all-4.1.0-incubating

  1. /**
  2.  * @since version3.4.6
  3.  */
  4. @Test(expected = org.apache.rocketmq.client.exception.MQBrokerException.class)
  5. public void testSend20kChinaPropMsg() throws Exception {
  6.   Message msg = MessageFactory.getRandomMessage(topic);
  7.   msg.putUserProperty("key", RandomUtils.getCheseWord(32 * 1024 + 1));
  8.   producer.send(msg);
  9. }

代码示例来源：origin: jiangxinlingdu/rocketmq-all-4.1.0-incubating

  1. @Test
  2.   public void testSendMsgWithUserProperty() {
  3.     Message msg = MessageFactory.getRandomMessage(topic);
  4.     msg.putUserProperty("key", RandomUtils.getCheseWord(10 * 1024));
  5.     SendResult sendResult = null;
  6.     try {
  7.       sendResult = producer.send(msg);
  8.     } catch (Exception e) {
  9.     }
  10.     assertThat(sendResult.getSendStatus()).isEqualTo(SendStatus.SEND_OK);
  11.   }
  12. }

内容来源于网络，如有侵权，请联系作者删除！

Message

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com