com.alibaba.rocketmq.common.message.Message.putProperty()方法的使用及代码示例

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

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

Message.putProperty介绍

暂无

代码示例

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

public void setTags(String tags) {
  this.putProperty(MessageConst.PROPERTY_TAGS, tags);
}

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

public void setKeys(String keys) {
  this.putProperty(MessageConst.PROPERTY_KEYS, keys);
}

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

public void setTags(String tags) {
  this.putProperty(MessageConst.PROPERTY_TAGS, tags);
}

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

public static void putProperty(final Message msg, final String name, final String value) {
  msg.putProperty(name, value);
}

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

public static void putProperty(final Message msg, final String name, final String value) {
  msg.putProperty(name, value);
}

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

public void setKeys(String keys) {
  this.putProperty(MessageConst.PROPERTY_KEYS, keys);
}

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

public static void putProperty(final Message msg, final String name, final String value) {
  msg.putProperty(name, value);
}

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

public void setBuyerId(String buyerId) {
  putProperty(MessageConst.PROPERTY_BUYER_ID, buyerId);
}

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

public void setKeys(String keys) {
  this.putProperty(MessageConst.PROPERTY_KEYS, keys);
}

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

public void setBuyerId(String buyerId) {
  putProperty(MessageConst.PROPERTY_BUYER_ID, buyerId);
}

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

public void setWaitStoreMsgOK(boolean waitStoreMsgOK) {
  this.putProperty(MessageConst.PROPERTY_WAIT_STORE_MSG_OK, Boolean.toString(waitStoreMsgOK));
}

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

public void setDelayTimeLevel(int level) {
  this.putProperty(MessageConst.PROPERTY_DELAY_TIME_LEVEL, String.valueOf(level));
}

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

public void setWaitStoreMsgOK(boolean waitStoreMsgOK) {
  this.putProperty(MessageConst.PROPERTY_WAIT_STORE_MSG_OK, Boolean.toString(waitStoreMsgOK));
}

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

public void setWaitStoreMsgOK(boolean waitStoreMsgOK) {
  this.putProperty(MessageConst.PROPERTY_WAIT_STORE_MSG_OK, Boolean.toString(waitStoreMsgOK));
}

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

public void putUserProperty(final String name, final String value) {
  if (MessageConst.systemKeySet.contains(name)) {
    throw new RuntimeException(String.format(
        "The Property<%s> is used by system, input another please", name));
  }
  this.putProperty(name, value);
}

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

public void putUserProperty(final String name, final String value) {
  if (MessageConst.systemKeySet.contains(name)) {
    throw new RuntimeException(String.format(
        "The Property<%s> is used by system, input another please", name));
  }
  this.putProperty(name, value);
}

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

public void putUserProperty(final String name, final String value) {
  if (MessageConst.systemKeySet.contains(name)) {
    throw new RuntimeException(String.format(
        "The Property<%s> is used by system, input another please", name));
  }
  this.putProperty(name, value);
}

代码示例来源: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());            
  }
}

代码示例来源: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());            
  }
}

相关文章