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

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

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

Message.setExpiration介绍

[英]Sets the expiration of this message.
[中]

代码示例

代码示例来源：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. private void applyExpiryDelay(Message message, SimpleString address) {
  2.  long expirationOverride = addressSettingsRepository.getMatch(address.toString()).getExpiryDelay();
  3.  // A -1 <expiry-delay> means don't do anything
  4.  if (expirationOverride >= 0) {
  5.    // only override the exiration on messages where the expiration hasn't been set by the user
  6.    if (message.getExpiration() == 0) {
  7.     message.setExpiration(System.currentTimeMillis() + expirationOverride);
  8.    }
  9.  }
  10. }

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

  1. msg.setExpiration(Long.parseLong(expiration));

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

  1. msg.setExpiration(Long.parseLong(expiration));

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

  1. @Test
  2. public void testExpired() {
  3.  Message message = new ClientMessageImpl();
  4.  Assert.assertEquals(0, message.getExpiration());
  5.  Assert.assertFalse(message.isExpired());
  6.  message.setExpiration(System.currentTimeMillis() + 1000);
  7.  Assert.assertFalse(message.isExpired());
  8.  message.setExpiration(System.currentTimeMillis() - 1);
  9.  Assert.assertTrue(message.isExpired());
  10.  message.setExpiration(System.currentTimeMillis() - 1000);
  11.  Assert.assertTrue(message.isExpired());
  12.  message.setExpiration(0);
  13.  Assert.assertFalse(message.isExpired());
  14. }

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

  1. private Message makeCopy(final MessageReference ref,
  2.             final boolean expiry,
  3.             final boolean copyOriginalHeaders) throws Exception {
  4.  if (ref == null) {
  5.    ActiveMQServerLogger.LOGGER.nullRefMessage();
  6.    throw new ActiveMQNullRefException("Reference to message is null");
  7.  }
  8.  Message message = ref.getMessage();
  9.  /*
  10.   We copy the message and send that to the dla/expiry queue - this is
  11.   because otherwise we may end up with a ref with the same message id in the
  12.   queue more than once which would barf - this might happen if the same message had been
  13.   expire from multiple subscriptions of a topic for example
  14.   We set headers that hold the original message address, expiry time
  15.   and original message id
  16.  */
  17.  long newID = storageManager.generateID();
  18.  Message copy = message.copy(newID);
  19.  if (copyOriginalHeaders) {
  20.    copy.referenceOriginalMessage(message, ref.getQueue().getName().toString());
  21.  }
  22.  copy.setExpiration(0);
  23.  if (expiry) {
  24.    copy.setAnnotation(Message.HDR_ACTUAL_EXPIRY_TIME, System.currentTimeMillis());
  25.  }
  26.  copy.reencode();
  27.  return copy;
  28. }

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

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

  1. copy.setExpiration(message.getExpiration());

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

  1. clientFile.setExpiration(System.currentTimeMillis());

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

  1. clientFile.setExpiration(System.currentTimeMillis());

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

  1. clientFile.setExpiration(System.currentTimeMillis());

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

  1. clientFile.setExpiration(System.currentTimeMillis());

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Message类方法

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