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

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

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

Message.setKeys介绍

暂无

代码示例

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

  1. public void setKeys(Collection<String> keys) {
  2.   StringBuffer sb = new StringBuffer();
  3.   for (String k : keys) {
  4.     sb.append(k);
  5.     sb.append(MessageConst.KEY_SEPARATOR);
  6.   }
  7.   this.setKeys(sb.toString().trim());
  8. }

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

  1. public Message(String topic, String tags, String keys, int flag, byte[] body, boolean waitStoreMsgOK) {
  2.   this.topic = topic;
  3.   this.flag = flag;
  4.   this.body = body;
  5.   if (tags != null && tags.length() > 0)
  6.     this.setTags(tags);
  7.   if (keys != null && keys.length() > 0)
  8.     this.setKeys(keys);
  9.   this.setWaitStoreMsgOK(waitStoreMsgOK);
  10. }

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

  1. msg.setKeys(String.valueOf(beginTimestamp / 1000));

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

  1. String value = properties.getProperty(name);
  2. if (MessageConst.PROPERTY_KEYS.equals(name)) {
  3.   rocketmqMsg.setKeys(value);
  4. } else if (MessageConst.PROPERTY_TAGS.equals(name)) {
  5.   rocketmqMsg.setTags(value);

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

  1. message.setKeys(keySet);
  2. try {
  3.   Set<String> traceBrokerSet = tryGetMessageQueueBrokerSet(traceProducer.getDefaultMQProducerImpl(), topic);

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

  1. toSend.setDelayTimeLevel(headerAccessor.getDelayTimeLevel());
  2. toSend.setTags(headerAccessor.getTags());
  3. toSend.setKeys(headerAccessor.getKeys());
  4. toSend.setFlag(headerAccessor.getFlag());
  5. for (Map.Entry<String, String> entry : headerAccessor.getUserProperties()

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

  1. public void setKeys(Collection<String> keys) {
  2.   StringBuffer sb = new StringBuffer();
  3.   for (String k : keys) {
  4.     sb.append(k);
  5.     sb.append(MessageConst.KEY_SEPARATOR);
  6.   }
  7.   this.setKeys(sb.toString().trim());
  8. }

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

  1. Message message = new Message();
  2. message.setTopic(topic);
  3. message.setKeys("keys123");
  4. message.setTags("tags123");
  5. message.setWaitStoreMsgOK(false);

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

  1. public Message(String topic, String tags, String keys, int flag, byte[] body, boolean waitStoreMsgOK) {
  2.   this.topic = topic;
  3.   this.flag = flag;
  4.   this.body = body;
  5.   if (tags != null && tags.length() > 0)
  6.     this.setTags(tags);
  7.   if (keys != null && keys.length() > 0)
  8.     this.setKeys(keys);
  9.   this.setWaitStoreMsgOK(waitStoreMsgOK);
  10. }

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

  1. Object keys = headers.get(MessageConst.PROPERTY_KEYS);
  2. if (!StringUtils.isEmpty(keys)) { // if headers has 'KEYS', set rocketMQ message key
  3.   rocketMsg.setKeys(keys.toString());

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

  1. msg.setKeys(String.valueOf(beginTimestamp / 1000));

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

  1. public void setKeys(Collection<String> keys) {
  2.   StringBuffer sb = new StringBuffer();
  3.   for (String k : keys) {
  4.     sb.append(k);
  5.     sb.append(MessageConst.KEY_SEPARATOR);
  6.   }
  7.   this.setKeys(sb.toString().trim());
  8. }

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

  1. public Message(String topic, String tags, String keys, int flag, byte[] body, boolean waitStoreMsgOK) {
  2.   this.topic = topic;
  3.   this.flag = flag;
  4.   this.body = body;
  5.   if (tags != null && tags.length() > 0)
  6.     this.setTags(tags);
  7.   if (keys != null && keys.length() > 0)
  8.     this.setKeys(keys);
  9.   this.setWaitStoreMsgOK(waitStoreMsgOK);
  10. }

代码示例来源：origin: openmessaging/openmessaging-benchmark

  1. @Override
  2. public CompletableFuture<Void> sendAsync(final Optional<String> key, final byte[] payload) {
  3.   Message message = new Message(this.rmqTopic, payload);
  4.   if (key.isPresent()) {
  5.     message.setKeys(key.get());
  6.   }
  7.   CompletableFuture<Void> future = new CompletableFuture<>();
  8.   try {
  9.     this.rmqProducer.send(message, new SendCallback() {
  10.       @Override
  11.       public void onSuccess(final SendResult sendResult) {
  12.         future.complete(null);
  13.       }
  14.       @Override
  15.       public void onException(final Throwable e) {
  16.         future.completeExceptionally(e);
  17.       }
  18.     });
  19.   } catch (Exception e) {
  20.     future.completeExceptionally(e);
  21.   }
  22.   return future;
  23. }

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

  1. Message message = new Message();
  2. message.setTopic(topic);
  3. message.setKeys("keys123");
  4. message.setTags("tags123");
  5. message.setWaitStoreMsgOK(false);

代码示例来源：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: maihaoche/rocketmq-spring-boot-starter

  1. message.setKeys(messageKey);

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

  1. Object keys = headers.get(RocketMQHeaders.KEYS);
  2. if (!StringUtils.isEmpty(keys)) { // if headers has 'KEYS', set rocketMQ message key
  3.   rocketMsg.setKeys(keys.toString());

代码示例来源：origin: maihaoche/rocketmq-spring-boot-starter

  1. /**
  2.  * 发送数据的接口
  3.  *
  4.  * @param keySet
  5.  *            本批次包含的keyset
  6.  * @param data
  7.  *            本批次的轨迹数据
  8.  */
  9. public void sendTraceDataByMQ(Set<String> keySet, String data) {
  10.   String topic = OnsTraceConstants.traceTopic;
  11.   final Message message = new Message(topic, data.getBytes());
  12.   message.setKeys(keySet);
  13.   try {
  14.     traceProducer.send(message, new SendCallback() {
  15.       @Override
  16.       public void onSuccess(SendResult sendResult) {
  17.       }
  18.       @Override
  19.       public void onException(Throwable e) {
  20.         //todo 对于发送失败的数据，如何保存，保证所有轨迹数据都记录下来
  21.         clientlog.info("send trace data failed ,the msgidSet is"+message.getKeys());
  22.       }
  23.     }, 5000);
  24.   }
  25.   catch (Exception e) {
  26.     clientlog.info("send trace data failed ,the msgidSet is"+message.getKeys());
  27.   }
  28. }

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

  1. message.setKeys(keySet);
  2. try {
  3.   Set<String> traceBrokerSet = tryGetMessageQueueBrokerSet(traceProducer.getDefaultMQProducerImpl(), topic);

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

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