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

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

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

Message.setBody介绍

暂无

代码示例

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

  1. private static Message buildMessage(final String topic, final int messageSize) throws UnsupportedEncodingException {
  2.   Message msg = new Message();
  3.   msg.setTopic(topic);
  4.   StringBuilder sb = new StringBuilder();
  5.   for (int i = 0; i < messageSize; i += 11) {
  6.     sb.append("hello jodie");
  7.   }
  8.   msg.setBody(sb.toString().getBytes(MixAll.DEFAULT_CHARSET));
  9.   return msg;
  10. }

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

  1. private static Message buildMessage(final int messageSize, final String topic) throws UnsupportedEncodingException {
  2.     Message msg = new Message();
  3.     msg.setTopic(topic);
  5.     StringBuilder sb = new StringBuilder();
  6.     for (int i = 0; i < messageSize; i += 10) {
  7.       sb.append("hello baby");
  8.     }
  10.     msg.setBody(sb.toString().getBytes(RemotingHelper.DEFAULT_CHARSET));
  12.     return msg;
  13.   }
  14. }

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

  1. public static Message decodeMessage(ByteBuffer byteBuffer) throws Exception {
  2.   Message message = new Message();
  3.   // 1 TOTALSIZE
  4.   byteBuffer.getInt();
  5.   // 2 MAGICCODE
  6.   byteBuffer.getInt();
  7.   // 3 BODYCRC
  8.   byteBuffer.getInt();
  9.   // 4 FLAG
  10.   int flag = byteBuffer.getInt();
  11.   message.setFlag(flag);
  12.   // 5 BODY
  13.   int bodyLen = byteBuffer.getInt();
  14.   byte[] body = new byte[bodyLen];
  15.   byteBuffer.get(body);
  16.   message.setBody(body);
  17.   // 6 properties
  18.   short propertiesLen = byteBuffer.getShort();
  19.   byte[] propertiesBytes = new byte[propertiesLen];
  20.   byteBuffer.get(propertiesBytes);
  21.   message.setProperties(string2messageProperties(new String(propertiesBytes, CHARSET_UTF8)));
  22.   return message;
  23. }

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

  1. public static Message convert2RMQMessage(JmsBaseMessage jmsMsg) throws Exception {
  2.   Message rocketmqMsg = new MessageExt();
  3.   rocketmqMsg.setBody(MessageConverter.getContentFromJms(jmsMsg));

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

  1. private boolean tryToCompressMessage(final Message msg) {
  2.   if (msg instanceof MessageBatch) {
  3.     //batch dose not support compressing right now
  4.     return false;
  5.   }
  6.   byte[] body = msg.getBody();
  7.   if (body != null) {
  8.     if (body.length >= this.defaultMQProducer.getCompressMsgBodyOverHowmuch()) {
  9.       try {
  10.         byte[] data = UtilAll.compress(body, zipCompressLevel);
  11.         if (data != null) {
  12.           msg.setBody(data);
  13.           return true;
  14.         }
  15.       } catch (IOException e) {
  16.         log.error("tryToCompressMessage exception", e);
  17.         log.warn(msg.toString());
  18.       }
  19.     }
  20.   }
  21.   return false;
  22. }

代码示例来源：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: didi/DDMQ

  1. private static Message buildMessage(final int messageSize, final String topic) throws UnsupportedEncodingException {
  2.     Message msg = new Message();
  3.     msg.setTopic(topic);
  5.     StringBuilder sb = new StringBuilder();
  6.     for (int i = 0; i < messageSize; i += 10) {
  7.       sb.append("hello baby");
  8.     }
  10.     msg.setBody(sb.toString().getBytes(RemotingHelper.DEFAULT_CHARSET));
  12.     return msg;
  13.   }
  14. }

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

  1. private static Message buildMessage(final int messageSize) throws UnsupportedEncodingException {
  2.     Message msg = new Message();
  3.     msg.setTopic("BenchmarkTest");
  5.     StringBuilder sb = new StringBuilder();
  6.     for (int i = 0; i < messageSize; i += 10) {
  7.       sb.append("hello baby");
  8.     }
  10.     msg.setBody(sb.toString().getBytes(RemotingHelper.DEFAULT_CHARSET));
  12.     return msg;
  13.   }
  14. }

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

  1. private static Message buildMessage(final String topic, final int messageSize) throws UnsupportedEncodingException {
  2.   Message msg = new Message();
  3.   msg.setTopic(topic);
  4.   StringBuilder sb = new StringBuilder();
  5.   for (int i = 0; i < messageSize; i += 11) {
  6.     sb.append("hello jodie");
  7.   }
  8.   msg.setBody(sb.toString().getBytes(MixAll.DEFAULT_CHARSET));
  9.   return msg;
  10. }

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

  1. message.setBuyerId("buyerid123");
  2. message.setFlag(123);
  3. message.setBody("body".getBytes());
  4. messageList.add(message);

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

  1. msg.setBody(prevBody);
  2. msg.setBody(prevBody);

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

  1. public static Message decodeMessage(ByteBuffer byteBuffer) throws Exception {
  2.   Message message = new Message();
  3.   // 1 TOTALSIZE
  4.   byteBuffer.getInt();
  5.   // 2 MAGICCODE
  6.   byteBuffer.getInt();
  7.   // 3 BODYCRC
  8.   byteBuffer.getInt();
  9.   // 4 FLAG
  10.   int flag = byteBuffer.getInt();
  11.   message.setFlag(flag);
  12.   // 5 BODY
  13.   int bodyLen = byteBuffer.getInt();
  14.   byte[] body = new byte[bodyLen];
  15.   byteBuffer.get(body);
  16.   message.setBody(body);
  17.   // 6 properties
  18.   short propertiesLen = byteBuffer.getShort();
  19.   byte[] propertiesBytes = new byte[propertiesLen];
  20.   byteBuffer.get(propertiesBytes);
  21.   message.setProperties(string2messageProperties(new String(propertiesBytes, CHARSET_UTF8)));
  22.   return message;
  23. }

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

  1. private boolean tryToCompressMessage(final Message msg) {
  2.   if (msg instanceof MessageBatch) {
  3.     //batch dose not support compressing right now
  4.     return false;
  5.   }
  6.   byte[] body = msg.getBody();
  7.   if (body != null) {
  8.     if (body.length >= this.defaultMQProducer.getCompressMsgBodyOverHowmuch()) {
  9.       try {
  10.         byte[] data = UtilAll.compress(body, zipCompressLevel);
  11.         if (data != null) {
  12.           msg.setBody(data);
  13.           return true;
  14.         }
  15.       } catch (IOException e) {
  16.         log.error("tryToCompressMessage exception", e);
  17.         log.warn(msg.toString());
  18.       }
  19.     }
  20.   }
  21.   return false;
  22. }

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

  1. @Test(expected = org.apache.rocketmq.client.exception.MQClientException.class)
  2. public void testSynSendZeroSizeBodyMessage() throws Exception {
  3.   Message msg = new Message(topic, RandomUtils.getStringByUUID().getBytes());
  4.   msg.setBody(new byte[0]);
  5.   producer.send(msg);
  6. }

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

  1. @Test(expected = org.apache.rocketmq.client.exception.MQClientException.class)
  2. public void testSynSendOutOfSizeBodyMessage() throws Exception {
  3.   Message msg = new Message(topic, RandomUtils.getStringByUUID().getBytes());
  4.   msg.setBody(new byte[1024 * 1024 * 4 + 1]);
  5.   producer.send(msg);
  6. }

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

  1. @Test(expected = org.apache.rocketmq.client.exception.MQClientException.class)
  2. public void testSynSendNullBodyMessage() throws Exception {
  3.   Message msg = new Message(topic, RandomUtils.getStringByUUID().getBytes());
  4.   msg.setBody(null);
  5.   producer.send(msg);
  6. }

代码示例来源：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: org.apache.rocketmq/rocketmq-tools

  1. private static Message buildMessage(final String topic, final int messageSize) throws UnsupportedEncodingException {
  2.   Message msg = new Message();
  3.   msg.setTopic(topic);
  4.   StringBuilder sb = new StringBuilder();
  5.   for (int i = 0; i < messageSize; i += 11) {
  6.     sb.append("hello jodie");
  7.   }
  8.   msg.setBody(sb.toString().getBytes(MixAll.DEFAULT_CHARSET));
  9.   return msg;
  10. }

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

  1. message.setBuyerId("buyerid123");
  2. message.setFlag(123);
  3. message.setBody("body".getBytes());
  4. messageList.add(message);

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

  1. msg.setBody(prevBody);

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

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