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

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

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

Message.getProperties介绍

暂无

代码示例

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

  1. Message message = messages.get(nextIndex);
  2. int tmpSize = message.getTopic().length() + message.getBody().length;
  3. Map<String, String> properties = message.getProperties();
  4. for (Map.Entry<String, String> entry : properties.entrySet()) {
  5.   tmpSize += entry.getKey().length() + entry.getValue().length();

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

  1. String properties = messageProperties2String(message.getProperties());
  2. byte[] propertiesBytes = properties.getBytes(CHARSET_UTF8);

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

  1. /**
  2.  * Info,error,warn,callback method implementation
  3.  */
  4. public void append(LoggingEvent event) {
  5.   if (null == producer) {
  6.     return;
  7.   }
  8.   if (locationInfo) {
  9.     event.getLocationInformation();
  10.   }
  11.   byte[] data = this.layout.format(event).getBytes();
  12.   try {
  13.     Message msg = new Message(topic, tag, data);
  14.     msg.getProperties().put(ProducerInstance.APPENDER_TYPE, ProducerInstance.LOG4J_APPENDER);
  15.     //Send message and do not wait for the ack from the message broker.
  16.     producer.sendOneway(msg);
  17.   } catch (Exception e) {
  18.     String msg = new String(data);
  19.     errorHandler.error("Could not send message in RocketmqLog4jAppender [" + name + "].Message is :" + msg, e,
  20.       ErrorCode.GENERIC_FAILURE);
  21.   }
  22. }

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

  1. /**
  2.  * Info,error,warn,callback method implementation
  3.  */
  4. @Override
  5. protected void append(ILoggingEvent event) {
  6.   if (!isStarted()) {
  7.     return;
  8.   }
  9.   String logStr = this.layout.doLayout(event);
  10.   try {
  11.     Message msg = new Message(topic, tag, logStr.getBytes());
  12.     msg.getProperties().put(ProducerInstance.APPENDER_TYPE, ProducerInstance.LOGBACK_APPENDER);
  13.     //Send message and do not wait for the ack from the message broker.
  14.     producer.sendOneway(msg);
  15.   } catch (Exception e) {
  16.     addError("Could not send message in RocketmqLogbackAppender [" + name + "]. Message is : " + logStr, e);
  17.   }
  18. }

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

  1. if (msg.getProperties() != null) {
  2.   msg.getProperties().clear();

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

  1. /**
  2.  * Info,error,warn,callback method implementation
  3.  */
  4. public void append(LogEvent event) {
  5.   if (null == producer) {
  6.     return;
  7.   }
  8.   byte[] data = this.getLayout().toByteArray(event);
  9.   try {
  10.     Message msg = new Message(topic, tag, data);
  11.     msg.getProperties().put(ProducerInstance.APPENDER_TYPE, ProducerInstance.LOG4J2_APPENDER);
  12.     //Send message and do not wait for the ack from the message broker.
  13.     producer.sendOneway(msg);
  14.   } catch (Exception e) {
  15.     ErrorHandler handler = this.getHandler();
  16.     if (handler != null) {
  17.       String msg = new String(data);
  18.       handler.error("Could not send message in RocketmqLog4j2Appender [" + this.getName() + "].Message is : " + msg, e);
  19.     }
  20.   }
  21. }

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

  1. public static Message cloneMessage(final Message msg) {
  2.   Message newMsg = new Message(msg.getTopic(), msg.getBody());
  3.   newMsg.setFlag(msg.getFlag());
  4.   newMsg.setProperties(msg.getProperties());
  5.   return newMsg;
  6. }

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

  1. private MessageExtBrokerInner makeOpMessageInner(Message message, MessageQueue messageQueue) {
  2.   MessageExtBrokerInner msgInner = new MessageExtBrokerInner();
  3.   msgInner.setTopic(message.getTopic());
  4.   msgInner.setBody(message.getBody());
  5.   msgInner.setQueueId(messageQueue.getQueueId());
  6.   msgInner.setTags(message.getTags());
  7.   msgInner.setTagsCode(MessageExtBrokerInner.tagsString2tagsCode(msgInner.getTags()));
  8.   msgInner.setSysFlag(0);
  9.   MessageAccessor.setProperties(msgInner, message.getProperties());
  10.   msgInner.setPropertiesString(MessageDecoder.messageProperties2String(message.getProperties()));
  11.   msgInner.setBornTimestamp(System.currentTimeMillis());
  12.   msgInner.setBornHost(this.storeHost);
  13.   msgInner.setStoreHost(this.storeHost);
  14.   msgInner.setWaitStoreMsgOK(false);
  15.   MessageClientIDSetter.setUniqID(msgInner);
  16.   return msgInner;
  17. }

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

  1. requestHeader.setBornTimestamp(System.currentTimeMillis());
  2. requestHeader.setFlag(msg.getFlag());
  3. requestHeader.setProperties(MessageDecoder.messageProperties2String(msg.getProperties()));
  4. requestHeader.setReconsumeTimes(0);
  5. requestHeader.setUnitMode(this.isUnitMode());

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

  1. Message message = messages.get(nextIndex);
  2. int tmpSize = message.getTopic().length() + message.getBody().length;
  3. Map<String, String> properties = message.getProperties();
  4. for (Map.Entry<String, String> entry : properties.entrySet()) {
  5.   tmpSize += entry.getKey().length() + entry.getValue().length();

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

  1. String properties = messageProperties2String(message.getProperties());
  2. byte[] propertiesBytes = properties.getBytes(CHARSET_UTF8);

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

  1. /**
  2.  * Info,error,warn,callback method implementation
  3.  */
  4. public void append(LoggingEvent event) {
  5.   if (null == producer) {
  6.     return;
  7.   }
  8.   if (locationInfo) {
  9.     event.getLocationInformation();
  10.   }
  11.   byte[] data = this.layout.format(event).getBytes();
  12.   try {
  13.     Message msg = new Message(topic, tag, data);
  14.     msg.getProperties().put(ProducerInstance.APPENDER_TYPE, ProducerInstance.LOG4J_APPENDER);
  15.     //Send message and do not wait for the ack from the message broker.
  16.     producer.sendOneway(msg);
  17.   } catch (Exception e) {
  18.     String msg = new String(data);
  19.     errorHandler.error("Could not send message in RocketmqLog4jAppender [" + name + "].Message is :" + msg, e,
  20.       ErrorCode.GENERIC_FAILURE);
  21.   }
  22. }

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

  1. /**
  2.  * Info,error,warn,callback method implementation
  3.  */
  4. @Override
  5. protected void append(ILoggingEvent event) {
  6.   if (!isStarted()) {
  7.     return;
  8.   }
  9.   String logStr = this.layout.doLayout(event);
  10.   try {
  11.     Message msg = new Message(topic, tag, logStr.getBytes());
  12.     msg.getProperties().put(ProducerInstance.APPENDER_TYPE, ProducerInstance.LOGBACK_APPENDER);
  13.     //Send message and do not wait for the ack from the message broker.
  14.     producer.sendOneway(msg);
  15.   } catch (Exception e) {
  16.     addError("Could not send message in RocketmqLogbackAppender [" + name + "]. Message is : " + logStr, e);
  17.   }
  18. }

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

  1. if (msg.getProperties() != null) {
  2.   msg.getProperties().clear();

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

  1. /**
  2.  * Info,error,warn,callback method implementation
  3.  */
  4. public void append(LogEvent event) {
  5.   if (null == producer) {
  6.     return;
  7.   }
  8.   byte[] data = this.getLayout().toByteArray(event);
  9.   try {
  10.     Message msg = new Message(topic, tag, data);
  11.     msg.getProperties().put(ProducerInstance.APPENDER_TYPE, ProducerInstance.LOG4J2_APPENDER);
  12.     //Send message and do not wait for the ack from the message broker.
  13.     producer.sendOneway(msg);
  14.   } catch (Exception e) {
  15.     ErrorHandler handler = this.getHandler();
  16.     if (handler != null) {
  17.       String msg = new String(data);
  18.       handler.error("Could not send message in RocketmqLog4j2Appender [" + this.getName() + "].Message is : " + msg, e);
  19.     }
  20.   }
  21. }

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

  1. private SendMessageRequestHeader getMessageRequestHeader(Message msg, MessageQueue mq) {
  2.   SendMessageRequestHeader requestHeader = new SendMessageRequestHeader();
  3.   requestHeader.setProducerGroup(producer.getProducerGroup());
  4.   requestHeader.setTopic(msg.getTopic());
  5.   requestHeader.setDefaultTopic(producer.getCreateTopicKey());
  6.   requestHeader.setDefaultTopicQueueNums(producer.getDefaultTopicQueueNums());
  7.   requestHeader.setQueueId(mq.getQueueId());
  8.   requestHeader.setSysFlag(0);
  9.   requestHeader.setBornTimestamp(System.currentTimeMillis());
  10.   requestHeader.setFlag(msg.getFlag());
  11.   requestHeader.setProperties(MessageDecoder.messageProperties2String(msg.getProperties()));
  12.   requestHeader.setReconsumeTimes(0);
  13.   requestHeader.setUnitMode(producer.isUnitMode());
  14.   return requestHeader;
  15. }

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

  1. requestHeader.setBornTimestamp(System.currentTimeMillis());
  2. requestHeader.setFlag(msg.getFlag());
  3. requestHeader.setProperties(MessageDecoder.messageProperties2String(msg.getProperties()));
  4. requestHeader.setReconsumeTimes(0);
  5. requestHeader.setUnitMode(this.isUnitMode());

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

  1. public static Message cloneMessage(final Message msg) {
  2.   Message newMsg = new Message(msg.getTopic(), msg.getBody());
  3.   newMsg.setFlag(msg.getFlag());
  4.   newMsg.setProperties(msg.getProperties());
  5.   return newMsg;
  6. }

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

  1. private MessageExtBrokerInner makeOpMessageInner(Message message, MessageQueue messageQueue) {
  2.   MessageExtBrokerInner msgInner = new MessageExtBrokerInner();
  3.   msgInner.setTopic(message.getTopic());
  4.   msgInner.setBody(message.getBody());
  5.   msgInner.setQueueId(messageQueue.getQueueId());
  6.   msgInner.setTags(message.getTags());
  7.   msgInner.setTagsCode(MessageExtBrokerInner.tagsString2tagsCode(msgInner.getTags()));
  8.   msgInner.setSysFlag(0);
  9.   MessageAccessor.setProperties(msgInner, message.getProperties());
  10.   msgInner.setPropertiesString(MessageDecoder.messageProperties2String(message.getProperties()));
  11.   msgInner.setBornTimestamp(System.currentTimeMillis());
  12.   msgInner.setBornHost(this.storeHost);
  13.   msgInner.setStoreHost(this.storeHost);
  14.   msgInner.setWaitStoreMsgOK(false);
  15.   MessageClientIDSetter.setUniqID(msgInner);
  16.   return msgInner;
  17. }

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

  1. public static org.springframework.messaging.Message convertToSpringMessage(
  2.   org.apache.rocketmq.common.message.Message message) {
  3.   org.springframework.messaging.Message retMessage =
  4.     MessageBuilder.withPayload(message.getBody()).
  5.       setHeader(RocketMQHeaders.KEYS, message.getKeys()).
  6.       setHeader(RocketMQHeaders.TAGS, message.getTags()).
  7.       setHeader(RocketMQHeaders.TOPIC, message.getTopic()).
  8.       setHeader(RocketMQHeaders.FLAG, message.getFlag()).
  9.       setHeader(RocketMQHeaders.TRANSACTION_ID, message.getTransactionId()).
  10.       setHeader(RocketMQHeaders.PROPERTIES, message.getProperties()).
  11.       build();
  12.   return retMessage;
  13. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

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