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

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

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

Message.setTopic介绍

暂无

代码示例

代码示例来源：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. 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-externals

  1. rocketmqMsg.setTopic(topic);
  2. String messageType = destination.getMessageType();
  3. Preconditions.checkState(!messageType.contains("||"),

代码示例来源：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 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. 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 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. List<Message> messageList = new ArrayList<>();
  2. Message message = new Message();
  3. message.setTopic(topic);
  4. message.setKeys("keys123");
  5. message.setTags("tags123");

代码示例来源：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: jiangxinlingdu/rocketmq-all-4.1.0-incubating

  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: 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. List<Message> messageList = new ArrayList<>();
  2. Message message = new Message();
  3. message.setTopic(topic);
  4. message.setKeys("keys123");
  5. message.setTags("tags123");

代码示例来源：origin: rstyro/Springboot

  1. public void sendToMQ(Object object,String tags) throws Exception {
  2.   //构造消息数据
  3.   Message message = new Message();
  4.   //主题
  5.   message.setTopic(Const.PLAN_TOPIC);
  6.   message.setTags(tags);
  7.   //key
  8.   String uuid = UUID.randomUUID().toString();
  9.   message.setKeys(uuid);
  10.   message.setBody(JSON.toJSONString(object).getBytes());
  11.   //添加参数
  12.   Map<String, Object> transactionMapArgs = new HashMap<String, Object>();
  13.   this.planProducer.sendTransactionMessage(message, this.transactionExecuterImpl, transactionMapArgs);
  14. }

代码示例来源：origin: org.apache.rocketmq/rocketmq-openmessaging

  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. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

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