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

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

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

Message.getAnnotation介绍

暂无

代码示例

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

  1. default String getAnnotationString(SimpleString key) {
  2.  Object value = getAnnotation(key);
  3.  if (value != null) {
  4.    return value.toString();
  5.  } else {
  6.    return null;
  7.  }
  8. }

代码示例来源：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. 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 String getAnnotationString(SimpleString key) {
  2.  Object value = getAnnotation(key);
  3.  if (value != null) {
  4.    return value.toString();
  5.  } else {
  6.    return null;
  7.  }
  8. }

代码示例来源：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 String getAnnotationString(SimpleString key) {
  2.  Object value = getAnnotation(key);
  3.  if (value != null) {
  4.    return value.toString();
  5.  } else {
  6.    return null;
  7.  }
  8. }

代码示例来源：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 String getAnnotationString(SimpleString key) {
  2.  Object value = getAnnotation(key);
  3.  if (value != null) {
  4.    return value.toString();
  5.  } else {
  6.    return null;
  7.  }
  8. }

代码示例来源：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 String getAnnotationString(SimpleString key) {
  2.  Object value = getAnnotation(key);
  3.  if (value != null) {
  4.    return value.toString();
  5.  } else {
  6.    return null;
  7.  }
  8. }

代码示例来源：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 String getAnnotationString(SimpleString key) {
  2.  Object value = getAnnotation(key);
  3.  if (value != null) {
  4.    return value.toString();
  5.  } else {
  6.    return null;
  7.  }
  8. }

代码示例来源：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. }

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

  1. default String getAnnotationString(SimpleString key) {
  2.  Object value = getAnnotation(key);
  3.  if (value != null) {
  4.    return value.toString();
  5.  } else {
  6.    return null;
  7.  }
  8. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Message类方法

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