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

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

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

Message.isExpired介绍

[英]Returns whether this message is expired or not.
[中]返回此消息是否过期。

代码示例

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

  1. private boolean checkExpired(final MessageReference reference) {
  2. try {
  3. if (reference.getMessage().isExpired()) {
  4. if (logger.isTraceEnabled()) {
  5. logger.trace("Reference " + reference + " is expired");
  6. }
  7. reference.handled();
  8. try {
  9. expire(reference);
  10. } catch (Exception e) {
  11. ActiveMQServerLogger.LOGGER.errorExpiringRef(e);
  12. }
  13. return true;
  14. } else {
  15. return false;
  16. }
  17. } catch (Throwable e) {
  18. ActiveMQServerLogger.LOGGER.unableToCheckIfMessageExpired(e);
  19. return false;
  20. }
  21. }

代码示例来源: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. hasElements = true;
  2. MessageReference ref = iter.next();
  3. if (ref.getMessage().isExpired()) {
  4. incDelivering(ref);
  5. expired = true;

相关文章