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

Message.getProperty介绍

暂无

代码示例

代码示例来源：origin: com.alibaba.rocketmq/rocketmq-client

public static String getMQ2Flag(final Message msg) {
  return msg.getProperty(MessageConst.PROPERTY_MQ2_FLAG);
}

代码示例来源：origin: com.alibaba.rocketmq/rocketmq-common

public String getUserProperty(final String name) {
  return this.getProperty(name);
}

代码示例来源：origin: com.alibaba.rocketmq/rocketmq-common

public static String getConsumeStartTimeStamp(final Message msg) {
  return msg.getProperty(MessageConst.PROPERTY_CONSUME_START_TIMESTAMP);
}

代码示例来源：origin: com.alibaba.rocketmq/rocketmq-client

public String getTags() {
  return this.getProperty(MessageConst.PROPERTY_TAGS);
}

代码示例来源：origin: com.alibaba.rocketmq/rocketmq-client

public String getKeys() {
  return this.getProperty(MessageConst.PROPERTY_KEYS);
}

代码示例来源：origin: com.alibaba.rocketmq/rocketmq-common

public String getKeys() {
  return this.getProperty(MessageConst.PROPERTY_KEYS);
}

代码示例来源：origin: com.alibaba.rocketmq/rocketmq-common

public String getBuyerId() {
  return getProperty(MessageConst.PROPERTY_BUYER_ID);
}

代码示例来源：origin: com.alibaba.rocketmq/rocketmq-common

public static String getCorrectionFlag(final Message msg) {
  return msg.getProperty(MessageConst.PROPERTY_CORRECTION_FLAG);
}

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

public static String getConsumeStartTimeStamp(final Message msg) {
  return msg.getProperty(MessageConst.PROPERTY_CONSUME_START_TIMESTAMP);
}

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

public String getUserProperty(final String name) {
  return this.getProperty(name);
}

代码示例来源：origin: com.alibaba.rocketmq/rocketmq-client

public String getUserProperty(final String name) {
  return this.getProperty(name);
}

代码示例来源：origin: com.alibaba.rocketmq/rocketmq-client

public int getDelayTimeLevel() {
  String t = this.getProperty(MessageConst.PROPERTY_DELAY_TIME_LEVEL);
  if (t != null) {
    return Integer.parseInt(t);
  }
  return 0;
}

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

public boolean isWaitStoreMsgOK() {
  String result = this.getProperty(MessageConst.PROPERTY_WAIT_STORE_MSG_OK);
  if (null == result)
    return true;
  return Boolean.parseBoolean(result);
}

代码示例来源：origin: com.alibaba.rocketmq/rocketmq-common

public boolean isWaitStoreMsgOK() {
  String result = this.getProperty(MessageConst.PROPERTY_WAIT_STORE_MSG_OK);
  if (null == result)
    return true;
  return Boolean.parseBoolean(result);
}

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

public int getDelayTimeLevel() {
  String t = this.getProperty(MessageConst.PROPERTY_DELAY_TIME_LEVEL);
  if (t != null) {
    return Integer.parseInt(t);
  }
  return 0;
}

代码示例来源：origin: com.alibaba.rocketmq/rocketmq-client

public boolean isWaitStoreMsgOK() {
  String result = this.getProperty(MessageConst.PROPERTY_WAIT_STORE_MSG_OK);
  if (null == result)
    return true;
  return Boolean.parseBoolean(result);
}

代码示例来源：origin: com.alibaba.rocketmq/rocketmq-common

public int getDelayTimeLevel() {
  String t = this.getProperty(MessageConst.PROPERTY_DELAY_TIME_LEVEL);
  if (t != null) {
    return Integer.parseInt(t);
  }
  return 0;
}

代码示例来源：origin: com.alibaba.rocketmq/rocketmq-client

public static void setUniqID(final Message msg) {
  if (msg.getProperty(MessageConst.PROPERTY_UNIQ_CLIENT_MESSAGE_ID_KEYIDX) == null) {
    msg.putProperty(MessageConst.PROPERTY_UNIQ_CLIENT_MESSAGE_ID_KEYIDX, createUniqID());            
  }
}

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

public static void setUniqID(final Message msg) {
  if (msg.getProperty(MessageConst.PROPERTY_UNIQ_CLIENT_MESSAGE_ID_KEYIDX) == null) {
    msg.putProperty(MessageConst.PROPERTY_UNIQ_CLIENT_MESSAGE_ID_KEYIDX, createUniqID());            
  }
}

代码示例来源：origin: com.alibaba.rocketmq/rocketmq-common

public static void setUniqID(final Message msg) {
  if (msg.getProperty(MessageConst.PROPERTY_UNIQ_CLIENT_MESSAGE_ID_KEYIDX) == null) {
    msg.putProperty(MessageConst.PROPERTY_UNIQ_CLIENT_MESSAGE_ID_KEYIDX, createUniqID());            
  }
}