org.apache.activemq.command.Message.getProperties()方法的使用及代码示例

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

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

Message.getProperties介绍

暂无

代码示例

代码示例来源:origin: apache/activemq

@Override
public String toString(Map<String, Object>overrideFields) {
  try {
    getProperties();
  } catch (IOException e) {
  }
  return super.toString(overrideFields);
}

代码示例来源:origin: apache/activemq

} else if (brokerStats) {
  if (messageSend.getProperties().containsKey(STATS_BROKER_RESET_HEADER)) {
    getBrokerView().resetStatistics();

代码示例来源:origin: org.apache.activemq/activemq-all

@Override
public String toString(Map<String, Object>overrideFields) {
  try {
    getProperties();
  } catch (IOException e) {
  }
  return super.toString(overrideFields);
}

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

@Override
public String toString(Map<String, Object>overrideFields) {
  try {
    getProperties();
  } catch (IOException e) {
  }
  return super.toString(overrideFields);
}

代码示例来源:origin: org.apache.activemq/activemq-osgi

@Override
public String toString(Map<String, Object>overrideFields) {
  try {
    getProperties();
  } catch (IOException e) {
  }
  return super.toString(overrideFields);
}

代码示例来源:origin: pierre/meteo

@Override
  public String toString(Map<String, Object>overrideFields) {
    try {
      getProperties();
    } catch (IOException e) {
    }
    return super.toString(overrideFields);
  }
}

代码示例来源:origin: apache/activemq-artemis

private static void putMsgMarshalledProperties(final ByteSequence propBytes,
                       final Message messageSend,
                       final CoreMessage coreMessage) throws IOException {
 propBytes.compact();
 coreMessage.putBytesProperty(AMQ_MSG_MARSHALL_PROP, propBytes.data);
 //unmarshall properties to core so selector will work
 final Map<String, Object> props = messageSend.getProperties();
 if (!props.isEmpty()) {
   props.forEach((key, value) -> {
    try {
      coreMessage.putObjectProperty(key, value);
    } catch (ActiveMQPropertyConversionException e) {
      coreMessage.putStringProperty(key, value.toString());
    }
   });
 }
}

代码示例来源:origin: apache/activemq-artemis

if (connection.getContext().isFaultTolerant() && !messageSend.getProperties().containsKey(org.apache.activemq.artemis.api.core.Message.HDR_DUPLICATE_DETECTION_ID.toString())) {
  originalCoreMsg.putStringProperty(org.apache.activemq.artemis.api.core.Message.HDR_DUPLICATE_DETECTION_ID, SimpleString.toSimpleString(messageSend.getMessageId().toString()));

代码示例来源:origin: org.apache.activemq/activemq-osgi

} else if (brokerStats) {
  if (messageSend.getProperties().containsKey(STATS_BROKER_RESET_HEADER)) {
    getBrokerView().resetStatistics();

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

} else if (brokerStats) {
  if (messageSend.getProperties().containsKey(STATS_BROKER_RESET_HEADER)) {
    getBrokerView().resetStatistics();

代码示例来源:origin: org.apache.activemq/activemq-all

} else if (brokerStats) {
  if (messageSend.getProperties().containsKey(STATS_BROKER_RESET_HEADER)) {
    getBrokerView().resetStatistics();

相关文章

Message类方法