org.apache.activemq.artemis.api.core.Message.getAnnotationString()方法的使用及代码示例

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

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

Message.getAnnotationString介绍

暂无

代码示例

代码示例来源：origin: wildfly/wildfly

  1. default void referenceOriginalMessage(final Message original, String originalQueue) {
  2.  String queueOnMessage = original.getAnnotationString(Message.HDR_ORIGINAL_QUEUE);
  3.  if (queueOnMessage != null) {
  4.    setAnnotation(Message.HDR_ORIGINAL_QUEUE, queueOnMessage);
  5.  } else if (originalQueue != null) {
  6.    setAnnotation(Message.HDR_ORIGINAL_QUEUE, originalQueue);
  7.  }
  8.  Object originalID = original.getAnnotation(Message.HDR_ORIG_MESSAGE_ID);
  9.  if (originalID != null) {
  10.    setAnnotation(Message.HDR_ORIGINAL_ADDRESS, original.getAnnotationString(Message.HDR_ORIGINAL_ADDRESS));
  11.    setAnnotation(Message.HDR_ORIG_MESSAGE_ID, originalID);
  12.  } else {
  13.    setAnnotation(Message.HDR_ORIGINAL_ADDRESS, original.getAddress());
  14.    setAnnotation(Message.HDR_ORIG_MESSAGE_ID, original.getMessageID());
  15.  }
  16.  // reset expiry
  17.  setExpiration(0);
  18. }

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

  1. @Override
  2.   public void actMessage(Transaction tx, MessageReference ref) throws Exception {
  3.    String originalMessageAddress = ref.getMessage().getAnnotationString(Message.HDR_ORIGINAL_ADDRESS);
  4.    String originalMessageQueue = ref.getMessage().getAnnotationString(Message.HDR_ORIGINAL_QUEUE);
  5.    if (originalMessageAddress != null) {
  6.      incDelivering(ref);
  7.      Long targetQueue = null;
  8.      if (originalMessageQueue != null && !originalMessageQueue.equals(originalMessageAddress)) {
  9.       targetQueue = queues.get(originalMessageQueue);
  10.       if (targetQueue == null) {
  11.         Binding binding = postOffice.getBinding(SimpleString.toSimpleString(originalMessageQueue));
  12.         if (binding != null && binding instanceof LocalQueueBinding) {
  13.          targetQueue = ((LocalQueueBinding) binding).getID();
  14.          queues.put(originalMessageQueue, targetQueue);
  15.         }
  16.       }
  17.      }
  18.      if (targetQueue != null) {
  19.       move(SimpleString.toSimpleString(originalMessageAddress), tx, ref, false, false, targetQueue.longValue());
  20.      } else {
  21.       move(SimpleString.toSimpleString(originalMessageAddress), tx, ref, false, false);
  22.      }
  23.      refRemoved(ref);
  24.    }
  25.   }
  26. });

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

  1. default void referenceOriginalMessage(final Message original, String originalQueue) {
  2.  String queueOnMessage = original.getAnnotationString(Message.HDR_ORIGINAL_QUEUE);
  3.  if (queueOnMessage != null) {
  4.    setAnnotation(Message.HDR_ORIGINAL_QUEUE, queueOnMessage);
  5.  } else if (originalQueue != null) {
  6.    setAnnotation(Message.HDR_ORIGINAL_QUEUE, originalQueue);
  7.  }
  8.  Object originalID = original.getAnnotation(Message.HDR_ORIG_MESSAGE_ID);
  9.  if (originalID != null) {
  10.    setAnnotation(Message.HDR_ORIGINAL_ADDRESS, original.getAnnotationString(Message.HDR_ORIGINAL_ADDRESS));
  11.    setAnnotation(Message.HDR_ORIG_MESSAGE_ID, originalID);
  12.  } else {
  13.    setAnnotation(Message.HDR_ORIGINAL_ADDRESS, original.getAddress());
  14.    setAnnotation(Message.HDR_ORIG_MESSAGE_ID, original.getMessageID());
  15.  }
  16.  // reset expiry
  17.  setExpiration(0);
  18. }

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

  1. default void referenceOriginalMessage(final Message original, String originalQueue) {
  2.  String queueOnMessage = original.getAnnotationString(Message.HDR_ORIGINAL_QUEUE);
  3.  if (queueOnMessage != null) {
  4.    setAnnotation(Message.HDR_ORIGINAL_QUEUE, queueOnMessage);
  5.  } else if (originalQueue != null) {
  6.    setAnnotation(Message.HDR_ORIGINAL_QUEUE, originalQueue);
  7.  }
  8.  Object originalID = original.getAnnotation(Message.HDR_ORIG_MESSAGE_ID);
  9.  if (originalID != null) {
  10.    setAnnotation(Message.HDR_ORIGINAL_ADDRESS, original.getAnnotationString(Message.HDR_ORIGINAL_ADDRESS));
  11.    setAnnotation(Message.HDR_ORIG_MESSAGE_ID, originalID);
  12.  } else {
  13.    setAnnotation(Message.HDR_ORIGINAL_ADDRESS, original.getAddress());
  14.    setAnnotation(Message.HDR_ORIG_MESSAGE_ID, original.getMessageID());
  15.  }
  16.  // reset expiry
  17.  setExpiration(0);
  18. }

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

  1. default void referenceOriginalMessage(final Message original, String originalQueue) {
  2.  String queueOnMessage = original.getAnnotationString(Message.HDR_ORIGINAL_QUEUE);
  3.  if (queueOnMessage != null) {
  4.    setAnnotation(Message.HDR_ORIGINAL_QUEUE, queueOnMessage);
  5.  } else if (originalQueue != null) {
  6.    setAnnotation(Message.HDR_ORIGINAL_QUEUE, originalQueue);
  7.  }
  8.  Object originalID = original.getAnnotation(Message.HDR_ORIG_MESSAGE_ID);
  9.  if (originalID != null) {
  10.    setAnnotation(Message.HDR_ORIGINAL_ADDRESS, original.getAnnotationString(Message.HDR_ORIGINAL_ADDRESS));
  11.    setAnnotation(Message.HDR_ORIG_MESSAGE_ID, originalID);
  12.  } else {
  13.    setAnnotation(Message.HDR_ORIGINAL_ADDRESS, original.getAddress());
  14.    setAnnotation(Message.HDR_ORIG_MESSAGE_ID, original.getMessageID());
  15.  }
  16.  // reset expiry
  17.  setExpiration(0);
  18. }

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

  1. default void referenceOriginalMessage(final Message original, String originalQueue) {
  2.  String queueOnMessage = original.getAnnotationString(Message.HDR_ORIGINAL_QUEUE);
  3.  if (queueOnMessage != null) {
  4.    setAnnotation(Message.HDR_ORIGINAL_QUEUE, queueOnMessage);
  5.  } else if (originalQueue != null) {
  6.    setAnnotation(Message.HDR_ORIGINAL_QUEUE, originalQueue);
  7.  }
  8.  Object originalID = original.getAnnotation(Message.HDR_ORIG_MESSAGE_ID);
  9.  if (originalID != null) {
  10.    setAnnotation(Message.HDR_ORIGINAL_ADDRESS, original.getAnnotationString(Message.HDR_ORIGINAL_ADDRESS));
  11.    setAnnotation(Message.HDR_ORIG_MESSAGE_ID, originalID);
  12.  } else {
  13.    setAnnotation(Message.HDR_ORIGINAL_ADDRESS, original.getAddress());
  14.    setAnnotation(Message.HDR_ORIG_MESSAGE_ID, original.getMessageID());
  15.  }
  16.  // reset expiry
  17.  setExpiration(0);
  18. }

代码示例来源：origin: org.apache.activemq/artemis-jms-client-all

  1. default void referenceOriginalMessage(final Message original, String originalQueue) {
  2.  String queueOnMessage = original.getAnnotationString(Message.HDR_ORIGINAL_QUEUE);
  3.  if (queueOnMessage != null) {
  4.    setAnnotation(Message.HDR_ORIGINAL_QUEUE, queueOnMessage);
  5.  } else if (originalQueue != null) {
  6.    setAnnotation(Message.HDR_ORIGINAL_QUEUE, originalQueue);
  7.  }
  8.  Object originalID = original.getAnnotation(Message.HDR_ORIG_MESSAGE_ID);
  9.  if (originalID != null) {
  10.    setAnnotation(Message.HDR_ORIGINAL_ADDRESS, original.getAnnotationString(Message.HDR_ORIGINAL_ADDRESS));
  11.    setAnnotation(Message.HDR_ORIG_MESSAGE_ID, originalID);
  12.  } else {
  13.    setAnnotation(Message.HDR_ORIGINAL_ADDRESS, original.getAddress());
  14.    setAnnotation(Message.HDR_ORIG_MESSAGE_ID, original.getMessageID());
  15.  }
  16.  // reset expiry
  17.  setExpiration(0);
  18. }

代码示例来源：origin: org.jboss.eap/wildfly-client-all

  1. default void referenceOriginalMessage(final Message original, String originalQueue) {
  2.  String queueOnMessage = original.getAnnotationString(Message.HDR_ORIGINAL_QUEUE);
  3.  if (queueOnMessage != null) {
  4.    setAnnotation(Message.HDR_ORIGINAL_QUEUE, queueOnMessage);
  5.  } else if (originalQueue != null) {
  6.    setAnnotation(Message.HDR_ORIGINAL_QUEUE, originalQueue);
  7.  }
  8.  Object originalID = original.getAnnotation(Message.HDR_ORIG_MESSAGE_ID);
  9.  if (originalID != null) {
  10.    setAnnotation(Message.HDR_ORIGINAL_ADDRESS, original.getAnnotationString(Message.HDR_ORIGINAL_ADDRESS));
  11.    setAnnotation(Message.HDR_ORIG_MESSAGE_ID, originalID);
  12.  } else {
  13.    setAnnotation(Message.HDR_ORIGINAL_ADDRESS, original.getAddress());
  14.    setAnnotation(Message.HDR_ORIG_MESSAGE_ID, original.getMessageID());
  15.  }
  16.  // reset expiry
  17.  setExpiration(0);
  18. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Message类方法

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