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

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

本文整理了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

  1. @Override
  2. public String toString(Map<String, Object>overrideFields) {
  3. try {
  4. getProperties();
  5. } catch (IOException e) {
  6. }
  7. return super.toString(overrideFields);
  8. }

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

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

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

  1. @Override
  2. public String toString(Map<String, Object>overrideFields) {
  3. try {
  4. getProperties();
  5. } catch (IOException e) {
  6. }
  7. return super.toString(overrideFields);
  8. }

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

  1. @Override
  2. public String toString(Map<String, Object>overrideFields) {
  3. try {
  4. getProperties();
  5. } catch (IOException e) {
  6. }
  7. return super.toString(overrideFields);
  8. }

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

  1. @Override
  2. public String toString(Map<String, Object>overrideFields) {
  3. try {
  4. getProperties();
  5. } catch (IOException e) {
  6. }
  7. return super.toString(overrideFields);
  8. }

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

  1. @Override
  2. public String toString(Map<String, Object>overrideFields) {
  3. try {
  4. getProperties();
  5. } catch (IOException e) {
  6. }
  7. return super.toString(overrideFields);
  8. }
  9. }

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

  1. private static void putMsgMarshalledProperties(final ByteSequence propBytes,
  2. final Message messageSend,
  3. final CoreMessage coreMessage) throws IOException {
  4. propBytes.compact();
  5. coreMessage.putBytesProperty(AMQ_MSG_MARSHALL_PROP, propBytes.data);
  6. //unmarshall properties to core so selector will work
  7. final Map<String, Object> props = messageSend.getProperties();
  8. if (!props.isEmpty()) {
  9. props.forEach((key, value) -> {
  10. try {
  11. coreMessage.putObjectProperty(key, value);
  12. } catch (ActiveMQPropertyConversionException e) {
  13. coreMessage.putStringProperty(key, value.toString());
  14. }
  15. });
  16. }
  17. }

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

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

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

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

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

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

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

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

相关文章

Message类方法